CommT
- type of the committable@Experimental public class CommittableSummary<CommT> extends Object implements CommittableMessage<CommT>
It is sent to down-stream consumers to depict the progress of the committing process.
Constructor and Description |
---|
CommittableSummary(int subtaskId,
int numberOfSubtasks,
Long checkpointId,
int numberOfCommittables,
int numberOfPendingCommittables,
int numberOfFailedCommittables) |
Modifier and Type | Method and Description |
---|---|
OptionalLong |
getCheckpointId()
Returns the checkpoint id or empty if the message does not belong to a checkpoint.
|
int |
getNumberOfCommittables() |
int |
getNumberOfFailedCommittables() |
int |
getNumberOfPendingCommittables() |
int |
getNumberOfSubtasks() |
int |
getSubtaskId()
The subtask that created this committable.
|
public int getSubtaskId()
CommittableMessage
getSubtaskId
in interface CommittableMessage<CommT>
public int getNumberOfSubtasks()
public OptionalLong getCheckpointId()
CommittableMessage
getCheckpointId
in interface CommittableMessage<CommT>
public int getNumberOfCommittables()
public int getNumberOfPendingCommittables()
public int getNumberOfFailedCommittables()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.