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

Interface WithPostCommitTopology<InputT,CommT>

All Superinterfaces:

Serializable, Sink<InputT>, SupportsCommitter<CommT>, SupportsPostCommitTopology<CommT>, TwoPhaseCommittingSink<InputT,CommT>

Deprecated.

Please implement Sink, SupportsCommitter and SupportsPostCommitTopology instead.

@Experimental
 @Deprecated
public interface WithPostCommitTopology<InputT,CommT>
extends TwoPhaseCommittingSink<InputT,CommT>, SupportsPostCommitTopology<CommT>

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.TwoPhaseCommittingSink

TwoPhaseCommittingSink.PrecommittingSinkWriter<InputT,CommT>

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

Sink.InitContext, Sink.InitContextWrapper

Method Summary

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

createCommitter, createCommitter

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.streaming.api.connector.sink2.SupportsPostCommitTopology

addPostCommitTopology