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

Packages that use BucketAssigner

Package	Description
<Unnamed>
org.apache.flink.sql.tests
org.apache.flink.streaming.api.functions.sink.filesystem
org.apache.flink.streaming.api.functions.sink.filesystem.bucketassigners
org.apache.flink.table.filesystem

Uses of BucketAssigner in <Unnamed>

Classes in <Unnamed> that implement BucketAssigner

Modifier and Type	Class and Description
static class	StreamingFileSinkProgram.KeyBucketAssigner Use first field for buckets.

Uses of BucketAssigner in org.apache.flink.sql.tests

Classes in org.apache.flink.sql.tests that implement BucketAssigner

Modifier and Type	Class and Description
static class	StreamSQLTestProgram.KeyBucketAssigner Use first field for buckets.

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

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

Modifier and Type	Method and Description
T	HadoopPathBasedBulkFormatBuilder.withBucketAssigner(BucketAssigner<IN,BucketID> assigner)
T	StreamingFileSink.RowFormatBuilder.withBucketAssigner(BucketAssigner<IN,BucketID> assigner)
T	StreamingFileSink.BulkFormatBuilder.withBucketAssigner(BucketAssigner<IN,BucketID> assigner)
<ID> StreamingFileSink.BulkFormatBuilder<IN,ID,? extends StreamingFileSink.BulkFormatBuilder<IN,ID,?>>	StreamingFileSink.BulkFormatBuilder.withNewBucketAssigner(BucketAssigner<IN,ID> assigner)
<ID> StreamingFileSink.RowFormatBuilder<IN,ID,? extends StreamingFileSink.RowFormatBuilder<IN,ID,?>>	StreamingFileSink.RowFormatBuilder.withNewBucketAssignerAndPolicy(BucketAssigner<IN,ID> assigner, RollingPolicy<IN,ID> policy)

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

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)
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, Configuration configuration, BucketAssigner<IN,BucketID> assigner)
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)
RowFormatBuilder(Path basePath, Encoder<IN> encoder, BucketAssigner<IN,BucketID> bucketAssigner)
RowFormatBuilder(Path basePath, Encoder<IN> encoder, BucketAssigner<IN,BucketID> assigner, RollingPolicy<IN,BucketID> policy, long bucketCheckInterval, BucketFactory<IN,BucketID> bucketFactory, OutputFileConfig outputFileConfig)

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

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

Modifier and Type	Class and Description
class	BasePathBucketAssigner<T> A BucketAssigner that does not perform any bucketing of files.
class	DateTimeBucketAssigner<IN> A BucketAssigner that assigns to buckets based on current system time.

Uses of BucketAssigner in org.apache.flink.table.filesystem

Classes in org.apache.flink.table.filesystem that implement BucketAssigner

Modifier and Type	Class and Description
static class	FileSystemTableSink.TableBucketAssigner Table bucket assigner, wrap PartitionComputer.