org.apache.flink.streaming.api.connector.sink2

Interface WithPreWriteTopology<InputT>

All Superinterfaces:

Serializable, Sink<InputT>

@Experimental
public interface WithPreWriteTopology<InputT>
extends Sink<InputT>

Allows expert users to implement a custom topology before SinkWriter.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.api.connector.sink2.Sink

Sink.InitContext

Method Summary

Modifier and Type	Method and Description
DataStream<InputT>	addPreWriteTopology(DataStream<InputT> inputDataStream) Adds an arbitrary topology before the writer.

Methods inherited from interface org.apache.flink.api.connector.sink2.Sink

createWriter

Method Detail

addPreWriteTopology

DataStream<InputT> addPreWriteTopology(DataStream<InputT> inputDataStream)

Adds an arbitrary topology before the writer. The topology may be used to repartition the data.

Parameters:

inputDataStream - the stream of input records.

Returns:

the custom topology before SinkWriter.