Package | Description |
---|---|
org.apache.flink.connector.testframe.environment | |
org.apache.flink.connector.testframe.testsuites | |
org.apache.flink.tests.util.flink |
Modifier and Type | Class and Description |
---|---|
class |
MiniClusterTestEnvironment
Test environment for running jobs on Flink mini-cluster.
|
Modifier and Type | Method and Description |
---|---|
void |
SinkTestSuiteBase.testBasicSink(TestEnvironment testEnv,
DataStreamSinkExternalContext<T> externalContext,
CheckpointingMode semantic)
Test DataStream connector sink.
|
void |
SourceTestSuiteBase.testIdleReader(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector source with an idle reader.
|
void |
SinkTestSuiteBase.testMetrics(TestEnvironment testEnv,
DataStreamSinkExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector sink metrics.
|
void |
SourceTestSuiteBase.testMultipleSplits(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector source with multiple splits in the external system
|
void |
SourceTestSuiteBase.testSavepoint(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector source restart from a savepoint.
|
void |
SinkTestSuiteBase.testScaleDown(TestEnvironment testEnv,
DataStreamSinkExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector sink restart from a completed savepoint with a lower parallelism.
|
void |
SourceTestSuiteBase.testScaleDown(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector source restart from a savepoint with a lower parallelism.
|
void |
SinkTestSuiteBase.testScaleUp(TestEnvironment testEnv,
DataStreamSinkExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector sink restart from a completed savepoint with a higher parallelism.
|
void |
SourceTestSuiteBase.testScaleUp(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector source restart from a savepoint with a higher parallelism.
|
void |
SourceTestSuiteBase.testSourceMetrics(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector source metrics.
|
void |
SourceTestSuiteBase.testSourceSingleSplit(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector source with only one split in the external system.
|
void |
SinkTestSuiteBase.testStartFromSavepoint(TestEnvironment testEnv,
DataStreamSinkExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector sink restart from a completed savepoint with the same parallelism.
|
void |
SourceTestSuiteBase.testTaskManagerFailure(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
ClusterControllable controller,
CheckpointingMode semantic)
Test connector source with task manager failover.
|
Modifier and Type | Class and Description |
---|---|
class |
FlinkContainerTestEnvironment
Test environment running job on
FlinkContainers . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.