CommT- The type of information needed to commit the staged data
@PublicEvolving public interface Committer<CommT> extends AutoCloseable
Committeris responsible for committing the data staged by the
TwoPhaseCommittingSink.PrecommittingSinkWriterin 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
|Modifier and Type||Interface and Description|
A request to commit a specific committable.
|Modifier and Type||Method and Description|
Commit the given list of
void commit(Collection<Committer.CommitRequest<CommT>> committables) throws IOException, InterruptedException
committables- A list of commit requests staged by the sink writer.
IOException- for reasons that may yield a complete restart of the job.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.