org.apache.flink.api.connector.sink2

Interface TwoPhaseCommittingSink<InputT,CommT>

Type Parameters:

InputT - The type of the sink's input

CommT - The type of the committables.

All Superinterfaces:

Serializable, Sink<InputT>, SupportsCommitter<CommT>

All Known Subinterfaces:

WithPostCommitTopology<InputT,CommT>, WithPreCommitTopology<InputT,CommT>

Deprecated.

Please implement Sink SupportsCommitter instead.

@PublicEvolving
 @Deprecated
public interface TwoPhaseCommittingSink<InputT,CommT>
extends Sink<InputT>, SupportsCommitter<CommT>

A Sink for exactly-once semantics using a two-phase commit protocol. The Sink consists of a SinkWriter that performs the precommits and a Committer that actually commits the data. To facilitate the separation the SinkWriter creates committables on checkpoint or end of input and the sends it to the Committer.

The TwoPhaseCommittingSink needs to be serializable. All configuration should be validated eagerly. The respective sink writers and committers are transient and will only be created in the subtasks on the taskmanagers.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	TwoPhaseCommittingSink.PrecommittingSinkWriter<InputT,CommT> Deprecated.

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

Sink.InitContext, Sink.InitContextWrapper

Method Summary

Modifier and Type	Method and Description
default Committer<CommT>	createCommitter() Deprecated. Please use createCommitter(CommitterInitContext)
default Committer<CommT>	createCommitter(CommitterInitContext context) Deprecated. Creates a Committer that permanently makes the previously written data visible through Committer.commit(Collection).

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

Method Detail

createCommitter

@Deprecated
default Committer<CommT> createCommitter()
                                              throws IOException

Deprecated. Please use createCommitter(CommitterInitContext)

Creates a Committer that permanently makes the previously written data visible through Committer.commit(Collection).

Returns:

A committer for the two-phase commit protocol.

Throws:

IOException - for any failure during creation.

createCommitter

default Committer<CommT> createCommitter(CommitterInitContext context)
                                  throws IOException

Deprecated.

Creates a Committer that permanently makes the previously written data visible through Committer.commit(Collection).

Specified by:

createCommitter in interface SupportsCommitter<CommT>

Parameters:

context - The context information for the committer initialization.

Returns:

A committer for the two-phase commit protocol.

Throws:

IOException - for any failure during creation.