Package | Description |
---|---|
org.apache.flink.connector.file.table |
Modifier and Type | Class and Description |
---|---|
class |
MetastoreCommitPolicy
Partition commit policy to update metastore.
|
class |
SuccessFileCommitPolicy
Partition commit policy to add success file to directory.
|
Modifier and Type | Method and Description |
---|---|
List<PartitionCommitPolicy> |
PartitionCommitPolicyFactory.createPolicyChain(ClassLoader cl,
java.util.function.Supplier<FileSystem> fsSupplier)
Create a policy chain.
|
Constructor and Description |
---|
PartitionLoader(boolean overwrite,
FileSystem sourceFs,
TableMetaStoreFactory factory,
boolean isToLocal,
ObjectIdentifier identifier,
List<PartitionCommitPolicy> policies) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.