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
org.apache.flink.streaming.api.functions.sink.filesystem.legacy

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	Description
class	DefaultBucketFactoryImpl<IN,BucketID>	A factory returning buckets.

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

Constructor

Description

Buckets(org.apache.flink.core.fs.Path basePath, org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner<IN,BucketID> bucketAssigner, BucketFactory<IN,BucketID> bucketFactory, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<IN,BucketID> bucketWriter, org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy<IN,BucketID> rollingPolicy, int subtaskIndex, org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig outputFileConfig)

A constructor creating a new empty bucket manager.

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

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

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

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

Constructor	Description
BulkFormatBuilder(org.apache.flink.core.fs.Path basePath, org.apache.flink.api.common.serialization.BulkWriter.Factory<IN> writerFactory, 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, long bucketCheckInterval, BucketFactory<IN,BucketID> bucketFactory, org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig outputFileConfig)
RowFormatBuilder(org.apache.flink.core.fs.Path basePath, org.apache.flink.api.common.serialization.Encoder<IN> encoder, org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner<IN,BucketID> assigner, org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy<IN,BucketID> policy, long bucketCheckInterval, BucketFactory<IN,BucketID> bucketFactory, org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig outputFileConfig)