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 and 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 and Description
HadoopPathBasedBucketWriter(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 and Description
HadoopPathBasedBulkFormatBuilder(org.apache.hadoop.fs.Path basePath, HadoopPathBasedBulkWriter.Factory<IN> writerFactory, HadoopFileCommitterFactory fileCommitterFactory, Configuration configuration, BucketAssigner<IN,BucketID> assigner, CheckpointRollingPolicy<IN,BucketID> policy, BucketFactory<IN,BucketID> bucketFactory, OutputFileConfig outputFileConfig)