Package | Description |
---|---|
org.apache.flink.connector.testframe.external.sink | |
org.apache.flink.connector.testframe.testsuites |
Modifier and Type | Interface and Description |
---|---|
interface |
DataStreamSinkV1ExternalContext<T>
External context for DataStream sinks whose version is V1.
|
interface |
DataStreamSinkV2ExternalContext<T>
External context for DataStream sinks whose version is V2.
|
Modifier and Type | Method and Description |
---|---|
protected List<T> |
SinkTestSuiteBase.generateTestData(TestingSinkSettings testingSinkSettings,
DataStreamSinkExternalContext<T> externalContext)
Generate a set of test records.
|
void |
SinkTestSuiteBase.testBasicSink(TestEnvironment testEnv,
DataStreamSinkExternalContext<T> externalContext,
CheckpointingMode semantic)
Test DataStream connector sink.
|
void |
SinkTestSuiteBase.testMetrics(TestEnvironment testEnv,
DataStreamSinkExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector sink metrics.
|
void |
SinkTestSuiteBase.testScaleDown(TestEnvironment testEnv,
DataStreamSinkExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector sink restart from a completed 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 |
SinkTestSuiteBase.testStartFromSavepoint(TestEnvironment testEnv,
DataStreamSinkExternalContext<T> externalContext,
CheckpointingMode semantic)
Test connector sink restart from a completed savepoint with the same parallelism.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.