Interface SupportsPreWriteTopology<InputT>


  • @Experimental
    public interface SupportsPreWriteTopology<InputT>
    Allows expert users to implement a custom topology before SinkWriter.
    • 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.