Package org.apache.flink.streaming.runtime.operators.sink.committables

Interface CommittableManager<CommT>

Type Parameters:

CommT - type of the committable

All Known Subinterfaces:

CheckpointCommittableManager<CommT>

@Internal
public interface CommittableManager<CommT>

Internal wrapper to handle the committing of committables.

Method Summary

Modifier and Type	Method	Description
Collection<CommittableWithLineage<CommT>>	commit(boolean fullyReceived, org.apache.flink.api.connector.sink2.Committer<CommT> committer)	Commits all due committables.
CommittableSummary<CommT>	getSummary()	Returns a summary of the current commit progress.

Method Detail

getSummary

CommittableSummary<CommT> getSummary()

Returns a summary of the current commit progress.

commit

Collection<CommittableWithLineage<CommT>> commit(boolean fullyReceived,
                                                 org.apache.flink.api.connector.sink2.Committer<CommT> committer)
                                          throws IOException,
                                                 InterruptedException

Commits all due committables.

Parameters:

fullyReceived - only commit committables if all committables of this checkpoint for a subtask are received

committer - used to commit to the external system

Returns:

successfully committed committables with meta information

Throws:

IOException

InterruptedException