Package | Description |
---|---|
org.apache.paimon.crosspartition | |
org.apache.paimon.flink.sink | |
org.apache.paimon.flink.sink.cdc | |
org.apache.paimon.table.sink |
Modifier and Type | Class and Description |
---|---|
class |
KeyPartPartitionKeyExtractor
A
PartitionKeyExtractor to InternalRow with only key and partition fields. |
Modifier and Type | Method and Description |
---|---|
protected abstract SerializableFunction<TableSchema,PartitionKeyExtractor<T>> |
DynamicBucketSink.extractorFunction() |
protected SerializableFunction<TableSchema,PartitionKeyExtractor<InternalRow>> |
RowDynamicBucketSink.extractorFunction() |
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 and Description |
---|
HashBucketAssignerOperator(String commitUser,
Table table,
Integer numAssigners,
SerializableFunction<TableSchema,PartitionKeyExtractor<T>> extractorFunction,
boolean overwrite) |
Modifier and Type | Class and Description |
---|---|
class |
CdcRecordPartitionKeyExtractor
|
Modifier and Type | Method and Description |
---|---|
protected SerializableFunction<TableSchema,PartitionKeyExtractor<T>> |
CdcDynamicBucketSinkBase.extractorFunction() |
Modifier and Type | Class and Description |
---|---|
class |
RowPartitionKeyExtractor
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.