Uses of Interface
org.apache.paimon.utils.SerializableFunction

Packages that use SerializableFunction

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

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

Methods in org.apache.paimon.flink.sink that return SerializableFunction

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

Methods in org.apache.paimon.flink.sink with parameters of type SerializableFunction

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

Constructors in org.apache.paimon.flink.sink with parameters of type SerializableFunction

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

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

Methods in org.apache.paimon.flink.sink.cdc that return SerializableFunction

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

Uses of SerializableFunction in org.apache.paimon.flink.sink.index

Constructors in org.apache.paimon.flink.sink.index with parameters of type SerializableFunction

Constructor and Description
Factory(IndexBootstrap bootstrap, SerializableFunction<InternalRow,T> converter)

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

Methods in org.apache.paimon.table.sink with parameters of type SerializableFunction

Modifier and Type	Method and Description
static <T,R> ChannelComputer<R>	ChannelComputer.transform(ChannelComputer<T> input, SerializableFunction<R,T> converter)