org.apache.paimon.flink.sink.cdc

Class CdcRecordPartitionKeyExtractor

java.lang.Object

org.apache.paimon.flink.sink.cdc.CdcRecordPartitionKeyExtractor

All Implemented Interfaces:

PartitionKeyExtractor<CdcRecord>

public class CdcRecordPartitionKeyExtractor
extends Object
implements PartitionKeyExtractor<CdcRecord>

A PartitionKeyExtractor to InternalRow.

Constructor Summary

Constructors

Constructor and Description
CdcRecordPartitionKeyExtractor(TableSchema schema)

Method Summary

Modifier and Type	Method and Description
BinaryRow	partition(CdcRecord record)
BinaryRow	trimmedPrimaryKey(CdcRecord record)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CdcRecordPartitionKeyExtractor

public CdcRecordPartitionKeyExtractor(TableSchema schema)

Method Detail

partition

public BinaryRow partition(CdcRecord record)

Specified by:

partition in interface PartitionKeyExtractor<CdcRecord>

trimmedPrimaryKey

public BinaryRow trimmedPrimaryKey(CdcRecord record)

Specified by:

trimmedPrimaryKey in interface PartitionKeyExtractor<CdcRecord>