org.apache.paimon.table.sink

Class FixedBucketRowKeyExtractor

java.lang.Object

org.apache.paimon.table.sink.RowKeyExtractor

org.apache.paimon.table.sink.FixedBucketRowKeyExtractor

All Implemented Interfaces:

KeyAndBucketExtractor<InternalRow>

public class FixedBucketRowKeyExtractor
extends RowKeyExtractor

KeyAndBucketExtractor for InternalRow.

Field Summary

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

record

Constructor Summary

Constructors

Constructor and Description
FixedBucketRowKeyExtractor(TableSchema schema)

Method Summary

Modifier and Type	Method and Description
int	bucket()
void	setRecord(InternalRow record)

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

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

FixedBucketRowKeyExtractor

public FixedBucketRowKeyExtractor(TableSchema schema)

Method Detail

setRecord

public void setRecord(InternalRow record)

Specified by:

setRecord in interface KeyAndBucketExtractor<InternalRow>

Overrides:

setRecord in class RowKeyExtractor

bucket

public int bucket()