org.apache.paimon.table.sink

Class RowKeyExtractor

java.lang.Object

org.apache.paimon.table.sink.RowKeyExtractor

All Implemented Interfaces:

KeyAndBucketExtractor<InternalRow>

Direct Known Subclasses:

DynamicBucketRowKeyExtractor, FixedBucketRowKeyExtractor, UnawareBucketRowKeyExtractor

public abstract class RowKeyExtractor
extends Object
implements KeyAndBucketExtractor<InternalRow>

KeyAndBucketExtractor for InternalRow.

Field Summary

Fields

Modifier and Type	Field and Description
protected InternalRow	record

Constructor Summary

Constructors

Constructor and Description
RowKeyExtractor(TableSchema schema)

Method Summary

Modifier and Type	Method and Description
BinaryRow	logPrimaryKey()
BinaryRow	partition()
void	setRecord(InternalRow 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, bucket, bucketKeyHashCode

Field Detail

record

protected InternalRow record

Constructor Detail

RowKeyExtractor

public RowKeyExtractor(TableSchema schema)

Method Detail

setRecord

public void setRecord(InternalRow record)

Specified by:

setRecord in interface KeyAndBucketExtractor<InternalRow>

partition

public BinaryRow partition()

Specified by:

partition in interface KeyAndBucketExtractor<InternalRow>

trimmedPrimaryKey

public BinaryRow trimmedPrimaryKey()

Specified by:

trimmedPrimaryKey in interface KeyAndBucketExtractor<InternalRow>

logPrimaryKey

public BinaryRow logPrimaryKey()

Specified by:

logPrimaryKey in interface KeyAndBucketExtractor<InternalRow>