Uses of Interface
org.apache.flink.streaming.api.functions.sink.filesystem.BucketFactory

Packages that use BucketFactory

Package	Description
org.apache.flink.streaming.api.functions.sink.filesystem

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

Classes in org.apache.flink.streaming.api.functions.sink.filesystem that implement BucketFactory

Modifier and Type	Class and Description
class	DefaultBucketFactoryImpl<IN,BucketID> A factory returning buckets.

Methods in org.apache.flink.streaming.api.functions.sink.filesystem with parameters of type BucketFactory

Modifier and Type	Method and Description
T	HadoopPathBasedBulkFormatBuilder.withBucketFactory(BucketFactory<IN,BucketID> factory)

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

Constructor and Description
Buckets(Path basePath, BucketAssigner<IN,BucketID> bucketAssigner, BucketFactory<IN,BucketID> bucketFactory, BucketWriter<IN,BucketID> bucketWriter, RollingPolicy<IN,BucketID> rollingPolicy, int subtaskIndex, OutputFileConfig outputFileConfig) A constructor creating a new empty bucket manager.
BulkFormatBuilder(Path basePath, BulkWriter.Factory<IN> writerFactory, BucketAssigner<IN,BucketID> assigner, CheckpointRollingPolicy<IN,BucketID> policy, long bucketCheckInterval, BucketFactory<IN,BucketID> bucketFactory, OutputFileConfig outputFileConfig)
HadoopPathBasedBulkFormatBuilder(org.apache.hadoop.fs.Path basePath, HadoopPathBasedBulkWriter.Factory<IN> writerFactory, HadoopFileCommitterFactory fileCommitterFactory, org.apache.hadoop.conf.Configuration configuration, BucketAssigner<IN,BucketID> assigner, CheckpointRollingPolicy<IN,BucketID> policy, BucketFactory<IN,BucketID> bucketFactory, OutputFileConfig outputFileConfig)
RowFormatBuilder(Path basePath, Encoder<IN> encoder, BucketAssigner<IN,BucketID> assigner, RollingPolicy<IN,BucketID> policy, long bucketCheckInterval, BucketFactory<IN,BucketID> bucketFactory, OutputFileConfig outputFileConfig)