public class ManifestCommittable extends Object
Constructor and Description |
---|
ManifestCommittable(long identifier) |
ManifestCommittable(long identifier,
Long watermark) |
ManifestCommittable(long identifier,
Long watermark,
Map<Integer,Long> logOffsets,
List<CommitMessage> commitMessages) |
Modifier and Type | Method and Description |
---|---|
void |
addFileCommittable(CommitMessage commitMessage) |
void |
addLogOffset(int bucket,
long offset) |
boolean |
equals(Object o) |
List<CommitMessage> |
fileCommittables() |
int |
hashCode() |
long |
identifier() |
Map<Integer,Long> |
logOffsets() |
String |
toString() |
Long |
watermark() |
public void addFileCommittable(CommitMessage commitMessage)
public void addLogOffset(int bucket, long offset)
public long identifier()
public List<CommitMessage> fileCommittables()
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.