org.apache.paimon.flink.sink.cdc

Class CdcRecordKeyAndBucketExtractor

java.lang.Object

org.apache.paimon.flink.sink.cdc.CdcRecordKeyAndBucketExtractor

All Implemented Interfaces:

KeyAndBucketExtractor<CdcRecord>

public class CdcRecordKeyAndBucketExtractor
extends Object
implements KeyAndBucketExtractor<CdcRecord>

KeyAndBucketExtractor for CdcRecord.

Constructor Summary

Constructors

Constructor and Description
CdcRecordKeyAndBucketExtractor(TableSchema schema)

Method Summary

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

CdcRecordKeyAndBucketExtractor

public CdcRecordKeyAndBucketExtractor(TableSchema schema)

Method Detail

setRecord

public void setRecord(CdcRecord record)

Specified by:

setRecord in interface KeyAndBucketExtractor<CdcRecord>

partition

public BinaryRow partition()

Specified by:

partition in interface KeyAndBucketExtractor<CdcRecord>

bucket

public int bucket()

Specified by:

bucket in interface KeyAndBucketExtractor<CdcRecord>

trimmedPrimaryKey

public BinaryRow trimmedPrimaryKey()

Specified by:

trimmedPrimaryKey in interface KeyAndBucketExtractor<CdcRecord>

logPrimaryKey

public BinaryRow logPrimaryKey()

Specified by:

logPrimaryKey in interface KeyAndBucketExtractor<CdcRecord>