Uses of Interface
org.apache.flink.connector.file.table.PartitionCommitPolicy

Packages that use PartitionCommitPolicy

Package	Description
org.apache.flink.connector.file.table

Uses of PartitionCommitPolicy in org.apache.flink.connector.file.table

Classes in org.apache.flink.connector.file.table that implement PartitionCommitPolicy

Modifier and Type	Class	Description
class	MetastoreCommitPolicy	Partition commit policy to update metastore.
class	SuccessFileCommitPolicy	Partition commit policy to add success file to directory.

Methods in org.apache.flink.connector.file.table that return types with arguments of type PartitionCommitPolicy

Modifier and Type	Method	Description
List<PartitionCommitPolicy>	PartitionCommitPolicyFactory.createPolicyChain(ClassLoader cl, Supplier<org.apache.flink.core.fs.FileSystem> fsSupplier)	Create a policy chain.

Constructor parameters in org.apache.flink.connector.file.table with type arguments of type PartitionCommitPolicy

Constructor	Description
FileSystemCommitter(FileSystemFactory factory, TableMetaStoreFactory metaStoreFactory, boolean overwrite, org.apache.flink.core.fs.Path tmpPath, int partitionColumnSize, boolean isToLocal, org.apache.flink.table.catalog.ObjectIdentifier identifier, LinkedHashMap<String,String> staticPartitions, List<PartitionCommitPolicy> policies)
PartitionLoader(boolean overwrite, org.apache.flink.core.fs.FileSystem sourceFs, TableMetaStoreFactory factory, boolean isToLocal, org.apache.flink.table.catalog.ObjectIdentifier identifier, List<PartitionCommitPolicy> policies)