public class Committable extends Object
PrepareCommitOperator
.Modifier and Type | Class and Description |
---|---|
static class |
Committable.Kind
Kind of the produced Committable.
|
Constructor and Description |
---|
Committable(long checkpointId,
Committable.Kind kind,
Object wrappedCommittable) |
Modifier and Type | Method and Description |
---|---|
long |
checkpointId() |
Committable.Kind |
kind() |
String |
toString() |
Object |
wrappedCommittable() |
public Committable(long checkpointId, Committable.Kind kind, Object wrappedCommittable)
public long checkpointId()
public Committable.Kind kind()
public Object wrappedCommittable()
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.