Committer (Flink : Core 1.20.1-cp1 API)

Type Parameters:

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

All Superinterfaces:

AutoCloseable
```
@Public
public interface Committer<CommT>
extends AutoCloseable
```
The Committer is responsible for committing the data staged by the CommittingSinkWriter 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 Description

static interface Committer.CommitRequest<CommT>
A request to commit a specific committable.

Method Summary

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

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