Uses of Interface
org.apache.flink.formats.hadoop.bulk.HadoopFileCommitterFactory

Packages that use HadoopFileCommitterFactory

Package	Description
org.apache.flink.formats.hadoop.bulk
org.apache.flink.streaming.api.functions.sink.filesystem

Uses of HadoopFileCommitterFactory in org.apache.flink.formats.hadoop.bulk

Classes in org.apache.flink.formats.hadoop.bulk that implement HadoopFileCommitterFactory

Modifier and Type	Class	Description
class	DefaultHadoopFileCommitterFactory	The default hadoop file committer factory which always use HadoopRenameFileCommitter.

Constructors in org.apache.flink.formats.hadoop.bulk with parameters of type HadoopFileCommitterFactory

Constructor	Description
HadoopPathBasedBucketWriter(org.apache.hadoop.conf.Configuration configuration, HadoopPathBasedBulkWriter.Factory<IN> bulkWriterFactory, HadoopFileCommitterFactory fileCommitterFactory)

Uses of HadoopFileCommitterFactory in org.apache.flink.streaming.api.functions.sink.filesystem

Constructors in org.apache.flink.streaming.api.functions.sink.filesystem with parameters of type HadoopFileCommitterFactory

Constructor

Description

HadoopPathBasedBulkFormatBuilder(org.apache.hadoop.fs.Path basePath, HadoopPathBasedBulkWriter.Factory<IN> writerFactory, HadoopFileCommitterFactory fileCommitterFactory, org.apache.hadoop.conf.Configuration configuration, org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner<IN,BucketID> assigner, org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.CheckpointRollingPolicy<IN,BucketID> policy, org.apache.flink.streaming.api.functions.sink.filesystem.BucketFactory<IN,BucketID> bucketFactory, org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig outputFileConfig)