Package | Description |
---|---|
org.apache.flink.connectors.test.common.external | |
org.apache.flink.connectors.test.common.testsuites |
Modifier and Type | Method and Description |
---|---|
ExternalContext<T> |
ExternalContext.Factory.createExternalContext() |
Modifier and Type | Method and Description |
---|---|
protected List<T> |
SourceTestSuiteBase.generateAndWriteTestData(int splitIndex,
ExternalContext<T> externalContext)
Generate a set of test records and write it to the given split writer.
|
void |
SourceTestSuiteBase.testIdleReader(TestEnvironment testEnv,
ExternalContext<T> externalContext)
Test connector source with an idle reader.
|
void |
SourceTestSuiteBase.testMultipleSplits(TestEnvironment testEnv,
ExternalContext<T> externalContext)
Test connector source with multiple splits in the external system
|
void |
SourceTestSuiteBase.testSourceSingleSplit(TestEnvironment testEnv,
ExternalContext<T> externalContext)
Test connector source with only one split in the external system.
|
void |
SourceTestSuiteBase.testTaskManagerFailure(TestEnvironment testEnv,
ExternalContext<T> externalContext,
ClusterControllable controller)
Test connector source with task manager failover.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.