Uses of Class
org.apache.flink.connector.file.table.PartitionCommitPolicyFactory
-
Packages that use PartitionCommitPolicyFactory Package Description org.apache.flink.connector.file.table org.apache.flink.connector.file.table.batch org.apache.flink.connector.file.table.batch.compact -
-
Uses of PartitionCommitPolicyFactory in org.apache.flink.connector.file.table
Methods in org.apache.flink.connector.file.table with parameters of type PartitionCommitPolicyFactory Modifier and Type Method Description FileSystemOutputFormat.Builder<T>FileSystemOutputFormat.Builder. setPartitionCommitPolicyFactory(PartitionCommitPolicyFactory partitionCommitPolicyFactory) -
Uses of PartitionCommitPolicyFactory in org.apache.flink.connector.file.table.batch
Methods in org.apache.flink.connector.file.table.batch with parameters of type PartitionCommitPolicyFactory Modifier and Type Method Description static <T> DataStreamSink<?>BatchSink. createBatchCompactSink(DataStream<CompactMessages.CoordinatorInput> dataStream, StreamingFileSink.BucketsBuilder<T,String,? extends StreamingFileSink.BucketsBuilder<T,String,?>> builder, CompactReader.Factory<T> readFactory, FileSystemFactory fsFactory, TableMetaStoreFactory metaStoreFactory, PartitionCommitPolicyFactory partitionCommitPolicyFactory, String[] partitionColumns, LinkedHashMap<String,String> staticPartitionSpec, Path tmpPath, ObjectIdentifier identifier, long compactAverageSize, long compactTargetSize, boolean isToLocal, boolean overwrite, int compactParallelism, boolean compactParallelismConfigured) -
Uses of PartitionCommitPolicyFactory in org.apache.flink.connector.file.table.batch.compact
Constructors in org.apache.flink.connector.file.table.batch.compact with parameters of type PartitionCommitPolicyFactory Constructor Description BatchPartitionCommitterSink(FileSystemFactory fsFactory, TableMetaStoreFactory msFactory, boolean overwrite, boolean isToLocal, Path tmpPath, String[] partitionColumns, LinkedHashMap<String,String> staticPartitions, ObjectIdentifier identifier, PartitionCommitPolicyFactory partitionCommitPolicyFactory)
-