Uses of Interface
org.apache.flink.formats.hadoop.bulk.HadoopPathBasedBulkWriter.Factory
-
Packages that use HadoopPathBasedBulkWriter.Factory Package Description org.apache.flink.formats.hadoop.bulk org.apache.flink.streaming.api.functions.sink.filesystem -
-
Uses of HadoopPathBasedBulkWriter.Factory in org.apache.flink.formats.hadoop.bulk
Constructors in org.apache.flink.formats.hadoop.bulk with parameters of type HadoopPathBasedBulkWriter.Factory Constructor Description HadoopPathBasedBucketWriter(org.apache.hadoop.conf.Configuration configuration, HadoopPathBasedBulkWriter.Factory<IN> bulkWriterFactory, HadoopFileCommitterFactory fileCommitterFactory) -
Uses of HadoopPathBasedBulkWriter.Factory in org.apache.flink.streaming.api.functions.sink.filesystem
Constructors in org.apache.flink.streaming.api.functions.sink.filesystem with parameters of type HadoopPathBasedBulkWriter.Factory 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)HadoopPathBasedBulkFormatBuilder(org.apache.hadoop.fs.Path basePath, HadoopPathBasedBulkWriter.Factory<IN> writerFactory, org.apache.hadoop.conf.Configuration configuration, org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner<IN,BucketID> assigner)
-