org.apache.paimon.crosspartition

Class KeyPartPartitionKeyExtractor

java.lang.Object

org.apache.paimon.crosspartition.KeyPartPartitionKeyExtractor

All Implemented Interfaces:

PartitionKeyExtractor<InternalRow>

public class KeyPartPartitionKeyExtractor
extends Object
implements PartitionKeyExtractor<InternalRow>

A PartitionKeyExtractor to InternalRow with only key and partition fields.

Constructor Summary

Constructors

Constructor and Description
KeyPartPartitionKeyExtractor(TableSchema schema)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

KeyPartPartitionKeyExtractor

public KeyPartPartitionKeyExtractor(TableSchema schema)

Method Detail

partition

public BinaryRow partition(InternalRow record)

Specified by:

partition in interface PartitionKeyExtractor<InternalRow>

trimmedPrimaryKey

public BinaryRow trimmedPrimaryKey(InternalRow record)

Specified by:

trimmedPrimaryKey in interface PartitionKeyExtractor<InternalRow>