Interface DataStreamSinkV2ExternalContext<T>
-
- Type Parameters:
T
- Type of elements before serialization by sink
- All Superinterfaces:
AutoCloseable
,DataStreamSinkExternalContext<T>
,ExternalContext
,ResultTypeQueryable<T>
@Experimental public interface DataStreamSinkV2ExternalContext<T> extends DataStreamSinkExternalContext<T>
External context for DataStream sinks whose version is V2.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Sink<T>
createSink(TestingSinkSettings sinkSettings)
Create an instance ofSink
satisfying given options.-
Methods inherited from interface java.lang.AutoCloseable
close
-
Methods inherited from interface org.apache.flink.connector.testframe.external.sink.DataStreamSinkExternalContext
createSinkDataReader, generateTestData
-
Methods inherited from interface org.apache.flink.connector.testframe.external.ExternalContext
getConnectorJarPaths
-
Methods inherited from interface org.apache.flink.api.java.typeutils.ResultTypeQueryable
getProducedType
-
-
-
-
Method Detail
-
createSink
Sink<T> createSink(TestingSinkSettings sinkSettings) throws UnsupportedOperationException
Create an instance ofSink
satisfying given options.- Parameters:
sinkSettings
- settings of the sink- Throws:
UnsupportedOperationException
- if the provided option is not supported.
-
-