Committer (Flink : Core 1.20.2-cp1 API)

Type Parameters:

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

All Superinterfaces:

AutoCloseable
```
@Deprecated
@PublicEvolving
public interface Committer<CommT>
extends AutoCloseable
```
Deprecated.
Please use Committer.

The Committer is responsible for committing the data staged by the sink.

Method Summary

All Methods Instance Methods Abstract Methods Deprecated Methods
Modifier and Type	Method	Description
`List<CommT>`	`commit(List<CommT> committables)`	Deprecated. Commits the given list of `Committer` and returns a list of `Committer` that need to be re-committed.

Methods inherited from interface java.lang.AutoCloseable
close

- Method Detail
  - commit
```
List<CommT> commit(List<CommT> committables)
            throws IOException,
                   InterruptedException
```
    Deprecated.
    
    Commits the given list of Committer and returns a list of Committer that need to be re-committed. The elements of the return list must be a subset of the input list, so that successful committables can be inferred.
    
    Parameters:
    
    committables - A list of information needed to commit data staged by the sink.
    
    Returns:
    
    a list of Committer that need to be re-committed.
    
    Throws:
    
    IOException - if the commit operation fail and do not want to retry any more.
    
    InterruptedException