Package org.apache.flink.api.connector.sink

Interface GlobalCommitter<CommT,GlobalCommT>

Type Parameters:

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

GlobalCommT - The type of the aggregated committable

All Superinterfaces:

AutoCloseable

@Deprecated
@PublicEvolving
public interface GlobalCommitter<CommT,GlobalCommT>
extends AutoCloseable

Deprecated.

Please use WithPostCommitTopology with StandardSinkTopologies#addGlobalCommitter.

The GlobalCommitter is responsible for creating and committing an aggregated committable, which we call global committable (see combine(java.util.List<CommT>)).

The GlobalCommitter runs with parallelism equal to 1.

Method Summary

Modifier and Type	Method	Description
GlobalCommT	combine(List<CommT> committables)	Deprecated. Compute an aggregated committable from a list of committables.
List<GlobalCommT>	commit(List<GlobalCommT> globalCommittables)	Deprecated. Commits the given list of GlobalCommitter and returns a list of GlobalCommitter that need to be re-committed.
void	endOfInput()	Deprecated. Signals that there is no committable any more.
List<GlobalCommT>	filterRecoveredCommittables(List<GlobalCommT> globalCommittables)	Deprecated. Find out which global committables need to be retried when recovering from the failure.

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

filterRecoveredCommittables

List<GlobalCommT> filterRecoveredCommittables(List<GlobalCommT> globalCommittables)
                                       throws IOException

Deprecated.

Find out which global committables need to be retried when recovering from the failure.

Parameters:

globalCommittables - A list of GlobalCommitter for which we want to verify which ones were successfully committed and which ones did not.

Returns:

A list of GlobalCommitter that should be committed again.

Throws:

IOException - if fail to filter the recovered committables.

combine

GlobalCommT combine(List<CommT> committables)
             throws IOException

Deprecated.

Compute an aggregated committable from a list of committables.

Parameters:

committables - A list of GlobalCommitter to be combined into a GlobalCommitter.

Returns:

an aggregated committable

Throws:

IOException - if fail to combine the given committables.

commit

List<GlobalCommT> commit(List<GlobalCommT> globalCommittables)
                  throws IOException,
                         InterruptedException

Deprecated.

Commits the given list of GlobalCommitter and returns a list of GlobalCommitter 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:

globalCommittables - a list of GlobalCommitter.

Returns:

a list of GlobalCommitter that need to be re-committed.

Throws:

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

InterruptedException

endOfInput

void endOfInput()
         throws IOException,
                InterruptedException

Deprecated.

Signals that there is no committable any more.

Throws:

IOException - if fail to handle this notification.

InterruptedException