org.apache.paimon.table.sink

Class RowPartitionKeyExtractor

java.lang.Object

org.apache.paimon.table.sink.RowPartitionKeyExtractor

All Implemented Interfaces:

PartitionKeyExtractor<InternalRow>

public class RowPartitionKeyExtractor
extends Object
implements PartitionKeyExtractor<InternalRow>

A PartitionKeyExtractor to InternalRow.

Constructor Summary

Constructors

Constructor and Description
RowPartitionKeyExtractor(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

RowPartitionKeyExtractor

public RowPartitionKeyExtractor(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>