Package org.apache.flink.connector.testframe.external
-
Interface Summary Interface Description ExternalContext External context for interacting with external system in testing framework.ExternalContextFactory<C extends ExternalContext> Factory for creatingExternalContext.ExternalSystemDataReader<T> A data reader for consuming records from an external system.ExternalSystemSplitDataWriter<T> A data writer for writing records into aSourceSplitin the external system. -
Class Summary Class Description DefaultContainerizedExternalSystem<C extends org.testcontainers.containers.GenericContainer<C>> Default implementation of external system based on container.DefaultContainerizedExternalSystem.Builder<C extends org.testcontainers.containers.GenericContainer<C>> Builder forDefaultContainerizedExternalSystem.