@Experimental public class CommittableWithLineage<CommT> extends Object implements CommittableMessage<CommT>
TwoPhaseCommittingSink.PrecommittingSinkWriter
and Committer
.Constructor and Description |
---|
CommittableWithLineage(CommT committable,
Long checkpointId,
int subtaskId) |
Modifier and Type | Method and Description |
---|---|
OptionalLong |
getCheckpointId()
Returns the checkpoint id or empty if the message does not belong to a checkpoint.
|
CommT |
getCommittable() |
int |
getSubtaskId()
The subtask that created this committable.
|
public CommT getCommittable()
public int getSubtaskId()
CommittableMessage
getSubtaskId
in interface CommittableMessage<CommT>
public OptionalLong getCheckpointId()
CommittableMessage
getCheckpointId
in interface CommittableMessage<CommT>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.