org.apache.flink.connector.file.table

Class FileSystemTableSink.TableBucketAssigner

java.lang.Object

org.apache.flink.connector.file.table.FileSystemTableSink.TableBucketAssigner

All Implemented Interfaces:

Serializable, BucketAssigner<RowData,String>

Enclosing class:

FileSystemTableSink

public static class FileSystemTableSink.TableBucketAssigner
extends Object
implements BucketAssigner<RowData,String>

Table bucket assigner, wrap PartitionComputer.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner

BucketAssigner.Context

Constructor Summary

Constructors

Constructor and Description
TableBucketAssigner(PartitionComputer<RowData> computer)

Method Summary

Modifier and Type	Method and Description
String	getBucketId(RowData element, BucketAssigner.Context context) Returns the identifier of the bucket the provided element should be put into.
SimpleVersionedSerializer<String>	getSerializer()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TableBucketAssigner

public TableBucketAssigner(PartitionComputer<RowData> computer)

Method Detail

getBucketId

public String getBucketId(RowData element,
                          BucketAssigner.Context context)

Description copied from interface: BucketAssigner

Returns the identifier of the bucket the provided element should be put into.

Specified by:

getBucketId in interface BucketAssigner<RowData,String>

Parameters:

element - The current element being processed.

context - The context used by the current bucket assigner.

Returns:

A string representing the identifier of the bucket the element should be put into. The actual path to the bucket will result from the concatenation of the returned string and the base path provided during the initialization of the file sink.

getSerializer

public SimpleVersionedSerializer<String> getSerializer()

Specified by:

getSerializer in interface BucketAssigner<RowData,String>

Returns:

A SimpleVersionedSerializer capable of serializing/deserializing the elements of type BucketID. That is the type of the objects returned by the BucketAssigner.getBucketId(Object, BucketAssigner.Context).