org.apache.paimon.table.sink

Class DynamicBucketRowKeyExtractor

java.lang.Object

org.apache.paimon.table.sink.RowKeyExtractor

org.apache.paimon.table.sink.DynamicBucketRowKeyExtractor

All Implemented Interfaces:

KeyAndBucketExtractor<InternalRow>

public class DynamicBucketRowKeyExtractor
extends RowKeyExtractor

KeyAndBucketExtractor for InternalRow, just throws error when extract bucket from dynamic row.

Field Summary

Fields inherited from class org.apache.paimon.table.sink.RowKeyExtractor

record

Constructor Summary

Constructors

Constructor and Description
DynamicBucketRowKeyExtractor(TableSchema schema)

Method Summary

Modifier and Type	Method and Description
int	bucket()

Methods inherited from class org.apache.paimon.table.sink.RowKeyExtractor

logPrimaryKey, partition, setRecord, 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

DynamicBucketRowKeyExtractor

public DynamicBucketRowKeyExtractor(TableSchema schema)

Method Detail

bucket

public int bucket()