Interface SupportsPreWriteTopology<InputT>
-
@Experimental public interface SupportsPreWriteTopology<InputT>
Allows expert users to implement a custom topology beforeSinkWriter
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description DataStream<InputT>
addPreWriteTopology(DataStream<InputT> inputDataStream)
Adds an arbitrary topology before the writer.
-
-
-
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
.
-
-