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

Packages that use ChannelComputer

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

Uses of ChannelComputer in org.apache.paimon.flink.clone

Classes in org.apache.paimon.flink.clone that implement ChannelComputer

Modifier and Type	Class and Description
class	SnapshotHintChannelComputer ChannelComputer for distributing CloneFileInfo records into SnapshotHintOperator for recreate snapshot hints.

Uses of ChannelComputer in org.apache.paimon.flink.service

Methods in org.apache.paimon.flink.service that return ChannelComputer

Modifier and Type	Method and Description
static ChannelComputer<InternalRow>	QueryFileMonitor.createChannelComputer()

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

Classes in org.apache.paimon.flink.sink that implement ChannelComputer

Modifier and Type	Class and Description
class	BucketsRowChannelComputer ChannelComputer to partition RowData from CompactBucketsTable.
class	MultiTableCommittableChannelComputer ChannelComputer for MultiTableCommittable.
class	RowAssignerChannelComputer Hash key of a RowData.
class	RowDataChannelComputer ChannelComputer for InternalRow.
class	RowWithBucketChannelComputer Hash key of a RowData with bucket.

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

Modifier and Type	Method and Description
protected abstract ChannelComputer<T>	DynamicBucketSink.assignerChannelComputer(Integer numAssigners)
protected ChannelComputer<InternalRow>	RowDynamicBucketSink.assignerChannelComputer(Integer numAssigners)
protected abstract ChannelComputer<org.apache.flink.api.java.tuple.Tuple2<T,Integer>>	DynamicBucketSink.channelComputer2()
protected ChannelComputer<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>>	RowDynamicBucketSink.channelComputer2()

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

Modifier and Type	Method and Description
static <T> org.apache.flink.streaming.api.datastream.DataStream<T>	FlinkStreamPartitioner.partition(org.apache.flink.streaming.api.datastream.DataStream<T> input, ChannelComputer<T> channelComputer, Integer parallelism)

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

Constructor and Description
FlinkStreamPartitioner(ChannelComputer<T> channelComputer)

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

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

Modifier and Type	Class and Description
class	CdcFixedBucketChannelComputerBase<T> ChannelComputer for distributing CDC records into writers for fixed-bucket mode tables.
class	CdcMultiplexRecordChannelComputer ChannelComputer for CdcMultiplexRecord.
class	CdcRecordChannelComputer CdcFixedBucketChannelComputerBase for CdcRecord.

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

Modifier and Type	Method and Description
protected ChannelComputer<T>	CdcDynamicBucketSinkBase.assignerChannelComputer(Integer numAssigners)
protected ChannelComputer<org.apache.flink.api.java.tuple.Tuple2<T,Integer>>	CdcDynamicBucketSinkBase.channelComputer2()

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

Classes in org.apache.paimon.flink.sink.index that implement ChannelComputer

Modifier and Type	Class and Description
class	KeyPartRowChannelComputer A ChannelComputer for KeyPartOrRow and row.

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

Methods in org.apache.paimon.table.sink that return ChannelComputer

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

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

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