Uses of Interface
org.apache.flink.connector.testframe.environment.ClusterControllable
-
Packages that use ClusterControllable Package Description org.apache.flink.connector.testframe.container org.apache.flink.connector.testframe.environment org.apache.flink.connector.testframe.testsuites -
-
Uses of ClusterControllable in org.apache.flink.connector.testframe.container
Classes in org.apache.flink.connector.testframe.container that implement ClusterControllable Modifier and Type Class Description classFlinkContainerTestEnvironmentTest environment running job onFlinkContainers. -
Uses of ClusterControllable in org.apache.flink.connector.testframe.environment
Classes in org.apache.flink.connector.testframe.environment that implement ClusterControllable Modifier and Type Class Description classMiniClusterTestEnvironmentTest environment for running jobs on Flink mini-cluster. -
Uses of ClusterControllable in org.apache.flink.connector.testframe.testsuites
Methods in org.apache.flink.connector.testframe.testsuites with parameters of type ClusterControllable Modifier and Type Method Description voidSourceTestSuiteBase. testTaskManagerFailure(TestEnvironment testEnv, DataStreamSourceExternalContext<T> externalContext, ClusterControllable controller, org.apache.flink.core.execution.CheckpointingMode semantic)Test connector source with task manager failover.
-