WithPreWriteTopology (Flink : Streaming Java 1.18.1-cp7 API)

All Superinterfaces:

Serializable, org.apache.flink.api.connector.sink2.Sink<InputT>
```
@Experimental
public interface WithPreWriteTopology<InputT>
extends org.apache.flink.api.connector.sink2.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
  org.apache.flink.api.connector.sink2.Sink.InitContext

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.

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.