public class StoreCommitter extends Object implements Committer<Committable,ManifestCommittable>
Committer
for dynamic store.Committer.Context, Committer.Factory<CommitT,GlobalCommitT>
Constructor and Description |
---|
StoreCommitter(FileStoreTable table,
TableCommit commit,
Committer.Context context) |
Modifier and Type | Method and Description |
---|---|
boolean |
allowLogOffsetDuplicate() |
void |
close() |
ManifestCommittable |
combine(long checkpointId,
long watermark,
List<Committable> committables)
Compute an aggregated committable from a list of committables.
|
ManifestCommittable |
combine(long checkpointId,
long watermark,
ManifestCommittable manifestCommittable,
List<Committable> committables) |
void |
commit(List<ManifestCommittable> committables)
Commits the given
GlobalCommitT . |
int |
filterAndCommit(List<ManifestCommittable> globalCommittables,
boolean checkAppendFiles)
Filter out all
GlobalCommitT which have committed, and commit the remaining GlobalCommitT . |
boolean |
forceCreatingSnapshot() |
CommitterMetrics |
getCommitterMetrics() |
Map<Long,List<Committable>> |
groupByCheckpoint(Collection<Committable> committables) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createContext, filterAndCommit
public StoreCommitter(FileStoreTable table, TableCommit commit, Committer.Context context)
@VisibleForTesting public CommitterMetrics getCommitterMetrics()
public boolean forceCreatingSnapshot()
forceCreatingSnapshot
in interface Committer<Committable,ManifestCommittable>
public ManifestCommittable combine(long checkpointId, long watermark, List<Committable> committables)
Committer
combine
in interface Committer<Committable,ManifestCommittable>
public ManifestCommittable combine(long checkpointId, long watermark, ManifestCommittable manifestCommittable, List<Committable> committables)
combine
in interface Committer<Committable,ManifestCommittable>
public void commit(List<ManifestCommittable> committables) throws IOException, InterruptedException
Committer
GlobalCommitT
.commit
in interface Committer<Committable,ManifestCommittable>
IOException
InterruptedException
public int filterAndCommit(List<ManifestCommittable> globalCommittables, boolean checkAppendFiles)
Committer
GlobalCommitT
which have committed, and commit the remaining GlobalCommitT
.filterAndCommit
in interface Committer<Committable,ManifestCommittable>
public Map<Long,List<Committable>> groupByCheckpoint(Collection<Committable> committables)
groupByCheckpoint
in interface Committer<Committable,ManifestCommittable>
public void close() throws Exception
close
in interface AutoCloseable
Exception
public boolean allowLogOffsetDuplicate()
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.