Package | Description |
---|---|
org.apache.paimon.flink.sink | |
org.apache.paimon.flink.sink.cdc | |
org.apache.paimon.flink.sink.index | |
org.apache.paimon.table.sink |
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 | Method and Description |
---|---|
protected SerializableFunction<TableSchema,PartitionKeyExtractor<T>> |
CdcDynamicBucketSinkBase.extractorFunction() |
Constructor and Description |
---|
IndexBootstrapOperator(IndexBootstrap bootstrap,
SerializableFunction<InternalRow,T> converter) |
Modifier and Type | Method and Description |
---|---|
static <T,R> ChannelComputer<R> |
ChannelComputer.transform(ChannelComputer<T> input,
SerializableFunction<R,T> converter) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.