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

Packages that use BucketAssigner.Context

Package	Description
org.apache.flink.connector.file.sink
org.apache.flink.connector.file.table
org.apache.flink.sql.tests
org.apache.flink.streaming.api.functions.sink.filesystem
org.apache.flink.streaming.api.functions.sink.filesystem.bucketassigners

Uses of BucketAssigner.Context in org.apache.flink.connector.file.sink

Methods in org.apache.flink.connector.file.sink with parameters of type BucketAssigner.Context

Modifier and Type	Method and Description
String	FileSinkProgram.KeyBucketAssigner.getBucketId(Tuple2<Integer,Integer> element, BucketAssigner.Context context)

Uses of BucketAssigner.Context in org.apache.flink.connector.file.table

Methods in org.apache.flink.connector.file.table with parameters of type BucketAssigner.Context

Modifier and Type	Method and Description
String	FileSystemTableSink.TableBucketAssigner.getBucketId(RowData element, BucketAssigner.Context context)

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

Methods in org.apache.flink.sql.tests with parameters of type BucketAssigner.Context

Modifier and Type	Method and Description
String	StreamSQLTestProgram.KeyBucketAssigner.getBucketId(Row element, BucketAssigner.Context context)

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

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

Modifier and Type	Method and Description
BucketID	BucketAssigner.getBucketId(IN element, BucketAssigner.Context context) Returns the identifier of the bucket the provided element should be put into.

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

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

Modifier and Type	Method and Description
String	DateTimeBucketAssigner.getBucketId(IN element, BucketAssigner.Context context)
String	BasePathBucketAssigner.getBucketId(T element, BucketAssigner.Context context)