Interface CommittableMessage<CommT>
-
- All Known Implementing Classes:
CommittableSummary,CommittableWithLineage
@Experimental public interface CommittableMessage<CommT>The message send fromSinkWritertoCommitter.
-
-
Field Summary
Fields Modifier and Type Field Description static longEOIDeprecated.the special value is not used anymore at all (remove with Flink 2.2)
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Deprecated Methods Modifier and Type Method Description default OptionalLonggetCheckpointId()Deprecated.longgetCheckpointIdOrEOI()Deprecated.the special value EOI is not used anymoreintgetSubtaskId()The subtask that created this committable.
-
-
-
Field Detail
-
EOI
@Deprecated static final long EOI
Deprecated.the special value is not used anymore at all (remove with Flink 2.2)Special value for checkpointId for the end of input in case of batch commit or final checkpoint.- See Also:
- Constant Field Values
-
-
Method Detail
-
getSubtaskId
int getSubtaskId()
The subtask that created this committable.
-
getCheckpointId
@Deprecated default OptionalLong getCheckpointId()
Deprecated.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).- See Also:
getCheckpointIdOrEOI()
-
getCheckpointIdOrEOI
long getCheckpointIdOrEOI()
Deprecated.the special value EOI is not used anymoreReturns the checkpoint id or EOI if this message belong to the final checkpoint or the batch commit.
-
-