org.apache.paimon.flink.sink

Class RowDataKeyAndBucketExtractor

java.lang.Object

org.apache.paimon.flink.sink.RowDataKeyAndBucketExtractor

All Implemented Interfaces:

KeyAndBucketExtractor<org.apache.flink.table.data.RowData>

public class RowDataKeyAndBucketExtractor
extends Object
implements KeyAndBucketExtractor<org.apache.flink.table.data.RowData>

KeyAndBucketExtractor for RowData.

Constructor Summary

Constructors

Constructor and Description
RowDataKeyAndBucketExtractor(TableSchema schema)

Method Summary

Modifier and Type	Method and Description
int	bucket()
BinaryRow	logPrimaryKey()
BinaryRow	partition()
void	setRecord(org.apache.flink.table.data.RowData record)
BinaryRow	trimmedPrimaryKey()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.table.sink.KeyAndBucketExtractor

bucket, bucketKeyHashCode

Constructor Detail

RowDataKeyAndBucketExtractor

public RowDataKeyAndBucketExtractor(TableSchema schema)

Method Detail

setRecord

public void setRecord(org.apache.flink.table.data.RowData record)

Specified by:

setRecord in interface KeyAndBucketExtractor<org.apache.flink.table.data.RowData>

partition

public BinaryRow partition()

Specified by:

partition in interface KeyAndBucketExtractor<org.apache.flink.table.data.RowData>

bucket

public int bucket()

Specified by:

bucket in interface KeyAndBucketExtractor<org.apache.flink.table.data.RowData>

trimmedPrimaryKey

public BinaryRow trimmedPrimaryKey()

Specified by:

trimmedPrimaryKey in interface KeyAndBucketExtractor<org.apache.flink.table.data.RowData>

logPrimaryKey

public BinaryRow logPrimaryKey()

Specified by:

logPrimaryKey in interface KeyAndBucketExtractor<org.apache.flink.table.data.RowData>