protected List<T> |
SourceTestSuiteBase.generateAndWriteTestData(int splitIndex,
DataStreamSourceExternalContext<T> externalContext,
TestingSourceSettings testingSourceSettings) |
Generate a set of test records and write it to the given split writer.
|
protected List<T> |
SourceTestSuiteBase.generateTestDataForWriter(DataStreamSourceExternalContext<T> externalContext,
TestingSourceSettings sourceSettings,
int splitIndex,
ExternalSystemSplitDataWriter<T> writer) |
Generate a set of split writers.
|
void |
SourceTestSuiteBase.testIdleReader(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
org.apache.flink.core.execution.CheckpointingMode semantic) |
Test connector source with an idle reader.
|
void |
SourceTestSuiteBase.testMultipleSplits(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
org.apache.flink.core.execution.CheckpointingMode semantic) |
Test connector source with multiple splits in the external system
|
void |
SourceTestSuiteBase.testSavepoint(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
org.apache.flink.core.execution.CheckpointingMode semantic) |
Test connector source restart from a savepoint.
|
void |
SourceTestSuiteBase.testScaleDown(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
org.apache.flink.core.execution.CheckpointingMode semantic) |
Test connector source restart from a savepoint with a lower parallelism.
|
void |
SourceTestSuiteBase.testScaleUp(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
org.apache.flink.core.execution.CheckpointingMode semantic) |
Test connector source restart from a savepoint with a higher parallelism.
|
void |
SourceTestSuiteBase.testSourceMetrics(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
org.apache.flink.core.execution.CheckpointingMode semantic) |
Test connector source metrics.
|
void |
SourceTestSuiteBase.testSourceSingleSplit(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
org.apache.flink.core.execution.CheckpointingMode semantic) |
Test connector source with only one split in the external system.
|
void |
SourceTestSuiteBase.testTaskManagerFailure(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
ClusterControllable controller,
org.apache.flink.core.execution.CheckpointingMode semantic) |
Test connector source with task manager failover.
|
protected org.apache.flink.api.connector.source.Source<T,?,?> |
SourceTestSuiteBase.tryCreateSource(DataStreamSourceExternalContext<T> externalContext,
TestingSourceSettings sourceOptions) |
|