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

Interface WithPostCommitTopology<InputT,​CommT>

  • All Superinterfaces:
    Serializable, org.apache.flink.api.connector.sink2.Sink<InputT>, org.apache.flink.api.connector.sink2.SupportsCommitter<CommT>, SupportsPostCommitTopology<CommT>, org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink<InputT,​CommT>
    @Experimental
@Deprecated
public interface WithPostCommitTopology<InputT,​CommT>
extends org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink<InputT,​CommT>, SupportsPostCommitTopology<CommT>
    Deprecated.
    Please implement Sink, SupportsCommitter and SupportsPostCommitTopology instead.
    Allows expert users to implement a custom topology after 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

      • 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