org.apache.flink.api.connector.sink2

Interface Committer<CommT>

Type Parameters:

CommT - The type of information needed to commit the staged data

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

FileCommitter, SinkV1Adapter.GlobalCommitterAdapter

@PublicEvolving
public interface Committer<CommT>
extends AutoCloseable

The Committer is responsible for committing the data staged by the TwoPhaseCommittingSink.PrecommittingSinkWriter in the second step of a two-phase commit protocol.

A commit must be idempotent: If some failure occurs in Flink during commit phase, Flink will restart from previous checkpoint and re-attempt to commit all committables. Thus, some or all committables may have already been committed. These Committer.CommitRequests must not change the external system and implementers are asked to signal Committer.CommitRequest.signalAlreadyCommitted().

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	Committer.CommitRequest<CommT> A request to commit a specific committable.

Method Summary

Modifier and Type	Method and Description
void	commit(Collection<Committer.CommitRequest<CommT>> committables) Commit the given list of CommT.

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

commit

void commit(Collection<Committer.CommitRequest<CommT>> committables)
     throws IOException,
            InterruptedException

Commit the given list of CommT.

Parameters:

committables - A list of commit requests staged by the sink writer.

Throws:

IOException - for reasons that may yield a complete restart of the job.

InterruptedException