org.apache.paimon.table.sink

Class UnawareBucketRowKeyExtractor

java.lang.Object

org.apache.paimon.table.sink.RowKeyExtractor

org.apache.paimon.table.sink.UnawareBucketRowKeyExtractor

All Implemented Interfaces:

KeyAndBucketExtractor<InternalRow>

public class UnawareBucketRowKeyExtractor
extends RowKeyExtractor

Unaware bucket table put all records into bucket 0 (for comparability with old design).

Field Summary

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

record

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

LOG

Constructor Summary

Constructors

Constructor and Description
UnawareBucketRowKeyExtractor(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

UnawareBucketRowKeyExtractor

public UnawareBucketRowKeyExtractor(TableSchema schema)

Method Detail

bucket

public int bucket()