Interface CommittableMessage<CommT>
-
- All Known Implementing Classes:
CommittableSummary,CommittableWithLineage
@Experimental public interface CommittableMessage<CommT>The message send fromSinkWritertoCommitter.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description OptionalLonggetCheckpointId()Returns the checkpoint id or empty if the message does not belong to a checkpoint.intgetSubtaskId()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).
-
-