Uses of Interface
org.apache.paimon.table.sink.PartitionKeyExtractor

Packages that use PartitionKeyExtractor

Package	Description
org.apache.paimon.crosspartition
org.apache.paimon.flink.sink
org.apache.paimon.flink.sink.cdc
org.apache.paimon.table.sink

Uses of PartitionKeyExtractor in org.apache.paimon.crosspartition

Classes in org.apache.paimon.crosspartition that implement PartitionKeyExtractor

Modifier and Type	Class and Description
class	KeyPartPartitionKeyExtractor A PartitionKeyExtractor to InternalRow with only key and partition fields.

Uses of PartitionKeyExtractor in org.apache.paimon.flink.sink

Methods in org.apache.paimon.flink.sink that return types with arguments of type PartitionKeyExtractor

Modifier and Type	Method and Description
protected SerializableFunction<TableSchema,PartitionKeyExtractor<InternalRow>>	RowDynamicBucketSink.extractorFunction()
protected abstract SerializableFunction<TableSchema,PartitionKeyExtractor<T>>	DynamicBucketSink.extractorFunction()

Method parameters in org.apache.paimon.flink.sink with type arguments of type PartitionKeyExtractor

Modifier and Type	Method and Description
protected HashBucketAssignerOperator<T>	DynamicBucketSink.createHashBucketAssignerOperator(String commitUser, Table table, Integer numAssigners, SerializableFunction<TableSchema,PartitionKeyExtractor<T>> extractorFunction, boolean overwrite)

Constructor parameters in org.apache.paimon.flink.sink with type arguments of type PartitionKeyExtractor

Constructor and Description
HashBucketAssignerOperator(String commitUser, Table table, Integer numAssigners, SerializableFunction<TableSchema,PartitionKeyExtractor<T>> extractorFunction, boolean overwrite)

Uses of PartitionKeyExtractor in org.apache.paimon.flink.sink.cdc

Classes in org.apache.paimon.flink.sink.cdc that implement PartitionKeyExtractor

Modifier and Type	Class and Description
class	CdcRecordPartitionKeyExtractor A PartitionKeyExtractor to InternalRow.

Methods in org.apache.paimon.flink.sink.cdc that return types with arguments of type PartitionKeyExtractor

Modifier and Type	Method and Description
protected SerializableFunction<TableSchema,PartitionKeyExtractor<T>>	CdcDynamicBucketSinkBase.extractorFunction()

Uses of PartitionKeyExtractor in org.apache.paimon.table.sink

Classes in org.apache.paimon.table.sink that implement PartitionKeyExtractor

Modifier and Type	Class and Description
class	RowPartitionKeyExtractor A PartitionKeyExtractor to InternalRow.