public class TableCommit extends Object implements AutoCloseable
FileStoreCommit
and FileStoreExpire
to provide
snapshot commit and expiration.Constructor and Description |
---|
TableCommit(FileStoreCommit commit,
FileStoreExpire expire,
PartitionExpire partitionExpire) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
commit(List<ManifestCommittable> committables) |
void |
commit(long identifier,
List<FileCommittable> fileCommittables) |
List<ManifestCommittable> |
filterCommitted(List<ManifestCommittable> committables) |
TableCommit |
withCreateEmptyCommit(boolean createEmptyCommit) |
TableCommit |
withLock(Lock lock) |
TableCommit |
withOverwritePartition(Map<String,String> overwritePartition) |
TableCommit |
withOverwritePartitions(List<Map<String,String>> overwritePartitions) |
public TableCommit(FileStoreCommit commit, @Nullable FileStoreExpire expire, @Nullable PartitionExpire partitionExpire)
public TableCommit withOverwritePartition(@Nullable Map<String,String> overwritePartition)
public TableCommit withOverwritePartitions(@Nullable List<Map<String,String>> overwritePartitions)
public TableCommit withLock(Lock lock)
public TableCommit withCreateEmptyCommit(boolean createEmptyCommit)
public List<ManifestCommittable> filterCommitted(List<ManifestCommittable> committables)
public void commit(long identifier, List<FileCommittable> fileCommittables)
public void commit(List<ManifestCommittable> committables)
public void close() throws Exception
close
in interface AutoCloseable
Exception
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.