org.apache.flink.api.connector.sink

Interface Committer<CommT>

Type Parameters:

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

All Superinterfaces:

AutoCloseable

Deprecated.

Please use Committer.

@Deprecated
 @PublicEvolving
public interface Committer<CommT>
extends AutoCloseable

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

Method Summary

Modifier and Type	Method and Description
List<CommT>	commit(List<CommT> committables) Deprecated. Commits the given list of CommT and returns a list of CommT 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 CommT and returns a list of CommT 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 CommT that need to be re-committed.

Throws:

IOException - if the commit operation fail and do not want to retry any more.

InterruptedException