Uses of Class
org.apache.flink.connector.file.table.stream.PartitionCommitInfo

Packages that use PartitionCommitInfo

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

Uses of PartitionCommitInfo in org.apache.flink.connector.file.table.stream

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

Modifier and Type	Method	Description
static <T> org.apache.flink.streaming.api.datastream.DataStream<PartitionCommitInfo>	StreamingSink.compactionWriter(org.apache.flink.table.connector.ProviderContext providerContext, org.apache.flink.streaming.api.datastream.DataStream<T> inputStream, long bucketCheckInterval, 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,?>> bucketsBuilder, FileSystemFactory fsFactory, org.apache.flink.core.fs.Path path, CompactReader.Factory<T> readFactory, long targetFileSize, int parallelism, boolean parallelismConfigured)	Create a file writer with compaction operators by input stream.
static <T> org.apache.flink.streaming.api.datastream.DataStream<PartitionCommitInfo>	StreamingSink.writer(org.apache.flink.table.connector.ProviderContext providerContext, org.apache.flink.streaming.api.datastream.DataStream<T> inputStream, long bucketCheckInterval, 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,?>> bucketsBuilder, int parallelism, List<String> partitionKeys, org.apache.flink.configuration.Configuration conf, boolean parallelismConfigured)	Create a file writer by input stream.

Method parameters in org.apache.flink.connector.file.table.stream with type arguments of type PartitionCommitInfo

Modifier and Type	Method	Description
void	PartitionCommitter.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<PartitionCommitInfo> element)
static org.apache.flink.streaming.api.datastream.DataStreamSink<?>	StreamingSink.sink(org.apache.flink.table.connector.ProviderContext providerContext, org.apache.flink.streaming.api.datastream.DataStream<PartitionCommitInfo> writer, org.apache.flink.core.fs.Path locationPath, org.apache.flink.table.catalog.ObjectIdentifier identifier, List<String> partitionKeys, TableMetaStoreFactory msFactory, FileSystemFactory fsFactory, org.apache.flink.configuration.Configuration options)	Create a sink from file writer.