Uses of Interface
org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink

Packages that use TwoPhaseCommittingSink

Package	Description
org.apache.flink.connector.file.sink
org.apache.flink.connector.kafka.sink
org.apache.flink.connector.pulsar.sink
org.apache.flink.streaming.api.connector.sink2
org.apache.flink.streaming.runtime.operators.sink

Uses of TwoPhaseCommittingSink in org.apache.flink.connector.file.sink

Classes in org.apache.flink.connector.file.sink that implement TwoPhaseCommittingSink

Modifier and Type	Class and Description
class	FileSink<IN> A unified sink that emits its input elements to FileSystem files within buckets.

Uses of TwoPhaseCommittingSink in org.apache.flink.connector.kafka.sink

Classes in org.apache.flink.connector.kafka.sink that implement TwoPhaseCommittingSink

Modifier and Type	Class and Description
class	KafkaSink<IN> Flink Sink to produce data into a Kafka topic.

Uses of TwoPhaseCommittingSink in org.apache.flink.connector.pulsar.sink

Classes in org.apache.flink.connector.pulsar.sink that implement TwoPhaseCommittingSink

Modifier and Type	Class and Description
class	PulsarSink<IN> The Sink implementation of Pulsar.

Uses of TwoPhaseCommittingSink in org.apache.flink.streaming.api.connector.sink2

Subinterfaces of TwoPhaseCommittingSink in org.apache.flink.streaming.api.connector.sink2

Modifier and Type	Interface and Description
interface	WithPostCommitTopology<InputT,CommT> Allows expert users to implement a custom topology after Committer.
interface	WithPreCommitTopology<InputT,CommT> Allows expert users to implement a custom topology after SinkWriter and before Committer.

Uses of TwoPhaseCommittingSink in org.apache.flink.streaming.runtime.operators.sink

Constructors in org.apache.flink.streaming.runtime.operators.sink with parameters of type TwoPhaseCommittingSink

Constructor and Description
CommitterOperatorFactory(TwoPhaseCommittingSink<?,CommT> sink, boolean isBatchMode, boolean isCheckpointingEnabled)