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

Interface WithPreCommitTopology<InputT,​CommT>

  • All Superinterfaces:
    Serializable, org.apache.flink.api.connector.sink2.Sink<InputT>, org.apache.flink.api.connector.sink2.SupportsCommitter<CommT>, SupportsPreCommitTopology<CommT,​CommT>, org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink<InputT,​CommT>
    @Experimental
@Deprecated
public interface WithPreCommitTopology<InputT,​CommT>
extends org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink<InputT,​CommT>, SupportsPreCommitTopology<CommT,​CommT>
    Deprecated.
    Please implement Sink, SupportsCommitter and SupportsPreCommitTopology instead.
    Allows expert users to implement a custom topology after SinkWriter and before Committer.

    It is recommended to use immutable committables because mutating committables can have unexpected side-effects.

    • Nested Class Summary

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

        org.apache.flink.api.connector.sink2.Sink.InitContext, org.apache.flink.api.connector.sink2.Sink.InitContextWrapper

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

        org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink.PrecommittingSinkWriter<InputT extends Object,​CommT extends Object>

    • Method Summary

      All Methods Instance Methods Default Methods Deprecated Methods 
      Modifier and Type Method Description
      default org.apache.flink.core.io.SimpleVersionedSerializer<CommT> getWriteResultSerializer()
      Deprecated.
      Defaults to SupportsCommitter.getCommittableSerializer() for backward compatibility.

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

        createWriter, createWriter

      • Methods inherited from interface org.apache.flink.api.connector.sink2.SupportsCommitter

        getCommittableSerializer

      • Methods inherited from interface org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink

        createCommitter, createCommitter