org.apache.flink.streaming.api.connector.sink2

Interface CommittableMessage<CommT>

All Known Implementing Classes:

CommittableSummary, CommittableWithLineage

@Experimental
public interface CommittableMessage<CommT>

The message send from SinkWriter to Committer.

Method Summary

Modifier and Type	Method and Description
OptionalLong	getCheckpointId() Returns the checkpoint id or empty if the message does not belong to a checkpoint.
int	getSubtaskId() The subtask that created this committable.

Method Detail

getSubtaskId

int getSubtaskId()

The subtask that created this committable.

getCheckpointId

OptionalLong getCheckpointId()

Returns the checkpoint id or empty if the message does not belong to a checkpoint. In that case, the committable was created at the end of input (e.g., in batch mode).