Uses of Interface
org.apache.flink.connector.testframe.external.sink.DataStreamSinkExternalContext

Packages that use DataStreamSinkExternalContext

Package	Description
org.apache.flink.connector.testframe.external.sink
org.apache.flink.connector.testframe.testsuites

Uses of DataStreamSinkExternalContext in org.apache.flink.connector.testframe.external.sink

Subinterfaces of DataStreamSinkExternalContext in org.apache.flink.connector.testframe.external.sink

Modifier and Type	Interface	Description
interface	DataStreamSinkV2ExternalContext<T>	External context for DataStream sinks whose version is V2.

Uses of DataStreamSinkExternalContext in org.apache.flink.connector.testframe.testsuites

Methods in org.apache.flink.connector.testframe.testsuites with parameters of type DataStreamSinkExternalContext

Modifier and Type	Method	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, org.apache.flink.core.execution.CheckpointingMode semantic)	Test DataStream connector sink.
void	SinkTestSuiteBase.testMetrics(TestEnvironment testEnv, DataStreamSinkExternalContext<T> externalContext, org.apache.flink.core.execution.CheckpointingMode semantic)	Test connector sink metrics.
void	SinkTestSuiteBase.testScaleDown(TestEnvironment testEnv, DataStreamSinkExternalContext<T> externalContext, org.apache.flink.core.execution.CheckpointingMode semantic)	Test connector sink restart from a completed savepoint with a lower parallelism.
void	SinkTestSuiteBase.testScaleUp(TestEnvironment testEnv, DataStreamSinkExternalContext<T> externalContext, org.apache.flink.core.execution.CheckpointingMode semantic)	Test connector sink restart from a completed savepoint with a higher parallelism.
void	SinkTestSuiteBase.testStartFromSavepoint(TestEnvironment testEnv, DataStreamSinkExternalContext<T> externalContext, org.apache.flink.core.execution.CheckpointingMode semantic)	Test connector sink restart from a completed savepoint with the same parallelism.