org.apache.paimon.table.sink

Interface ChannelComputer<T>

Type Parameters:

T - type of record

All Superinterfaces:

Serializable

All Known Implementing Classes:

BucketsRowChannelComputer, CdcFixedBucketChannelComputerBase, CdcMultiplexRecordChannelComputer, CdcRecordChannelComputer, KeyPartRowChannelComputer, MultiTableCommittableChannelComputer, RowAssignerChannelComputer, RowDataChannelComputer, RowWithBucketChannelComputer, SnapshotHintChannelComputer

public interface ChannelComputer<T>
extends Serializable

A utility class to compute which downstream channel a given record should be sent to.

Method Summary

Modifier and Type	Method and Description
int	channel(T record)
static int	select(BinaryRow partition, int bucket, int numChannels)
static int	select(int bucket, int numChannels)
void	setup(int numChannels)
static <T,R> ChannelComputer<R>	transform(ChannelComputer<T> input, SerializableFunction<R,T> converter)

Method Detail

setup

void setup(int numChannels)

channel

int channel(T record)

select

static int select(BinaryRow partition,
                  int bucket,
                  int numChannels)

select

static int select(int bucket,
                  int numChannels)

transform

static <T,R> ChannelComputer<R> transform(ChannelComputer<T> input,
                                          SerializableFunction<R,T> converter)