public class WrappedManifestCommittable extends Object
Constructor and Description |
---|
WrappedManifestCommittable(long checkpointId,
long watermark) |
Modifier and Type | Method and Description |
---|---|
long |
checkpointId() |
ManifestCommittable |
computeCommittableIfAbsent(Identifier identifier,
long checkpointId,
long watermark) |
boolean |
equals(Object o) |
int |
hashCode() |
Map<Identifier,ManifestCommittable> |
manifestCommittables() |
void |
putManifestCommittable(Identifier identifier,
ManifestCommittable manifestCommittable) |
String |
toString() |
long |
watermark() |
public WrappedManifestCommittable(long checkpointId, long watermark)
public long checkpointId()
public long watermark()
public Map<Identifier,ManifestCommittable> manifestCommittables()
public ManifestCommittable computeCommittableIfAbsent(Identifier identifier, long checkpointId, long watermark)
public void putManifestCommittable(Identifier identifier, ManifestCommittable manifestCommittable)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.