CommittableMessage (Flink : Streaming Java 1.19.2-cp2 API)

All Known Implementing Classes:

CommittableSummary, CommittableWithLineage
```
@Experimental
public interface CommittableMessage<CommT>
```
The message send from SinkWriter to Committer.

Field Summary

Fields
Modifier and Type Field Description

static long EOI
Special value for checkpointId for the end of input in case of batch commit or final checkpoint.

Method Summary

All Methods Instance Methods Abstract Methods Default Methods Deprecated Methods
Modifier and Type	Method	Description
`default OptionalLong`	`getCheckpointId()`	Deprecated.
`long`	`getCheckpointIdOrEOI()`	Returns the checkpoint id or EOI if this message belong to the final checkpoint or the batch commit.
`int`	`getSubtaskId()`	The subtask that created this committable.

- Field Detail
  - EOI
```
static final long EOI
```
    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()
```
    Returns the checkpoint id or EOI if this message belong to the final checkpoint or the batch commit.