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> org.apache.flink.streaming.api.datastream.DataStreamSink<?>BatchSink. createBatchCompactSink(org.apache.flink.streaming.api.datastream.DataStream<CompactMessages.CoordinatorInput> dataStream, org.apache.flink.streaming.api.functions.sink.filesystem.legacy.StreamingFileSink.BucketsBuilder<T,String,? extends org.apache.flink.streaming.api.functions.sink.filesystem.legacy.StreamingFileSink.BucketsBuilder<T,String,?>> builder, CompactReader.Factory<T> readFactory, FileSystemFactory fsFactory, TableMetaStoreFactory metaStoreFactory, PartitionCommitPolicyFactory partitionCommitPolicyFactory, String[] partitionColumns, LinkedHashMap<String,String> staticPartitionSpec, org.apache.flink.core.fs.Path tmpPath, org.apache.flink.table.catalog.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, org.apache.flink.core.fs.Path tmpPath, String[] partitionColumns, LinkedHashMap<String,String> staticPartitions, org.apache.flink.table.catalog.ObjectIdentifier identifier, PartitionCommitPolicyFactory partitionCommitPolicyFactory)
-