public interface FileStoreCommit
Modifier and Type | Method and Description |
---|---|
void |
commit(ManifestCommittable committable,
Map<String,String> properties)
Commit from manifest committable.
|
List<ManifestCommittable> |
filterCommitted(List<ManifestCommittable> committableList)
Find out which manifest committable need to be retried when recovering from the failure.
|
void |
overwrite(List<Map<String,String>> partitions,
ManifestCommittable committable,
Map<String,String> properties)
Overwrite multiple partitions from manifest committable.
|
default void |
overwrite(Map<String,String> partition,
ManifestCommittable committable,
Map<String,String> properties)
Overwrite a single partition from manifest committable.
|
FileStoreCommit |
withCreateEmptyCommit(boolean createEmptyCommit) |
FileStoreCommit |
withLock(Lock lock)
With global lock.
|
FileStoreCommit withLock(Lock lock)
FileStoreCommit withCreateEmptyCommit(boolean createEmptyCommit)
List<ManifestCommittable> filterCommitted(List<ManifestCommittable> committableList)
void commit(ManifestCommittable committable, Map<String,String> properties)
default void overwrite(Map<String,String> partition, ManifestCommittable committable, Map<String,String> properties)
void overwrite(List<Map<String,String>> partitions, ManifestCommittable committable, Map<String,String> properties)
partitions
- A list of partition Map
s that maps each partition key to a
partition value. Depending on the user-defined statement, the partition might not include
all partition keys. Also note that this partition does not necessarily equal to the
partitions of the newly added key-values. This is just the partition to be cleaned up.Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.