org.apache.paimon.flink.sink.cdc

Class CdcFixedBucketChannelComputerBase<T>

java.lang.Object

org.apache.paimon.flink.sink.cdc.CdcFixedBucketChannelComputerBase<T>

All Implemented Interfaces:

Serializable, ChannelComputer<T>

Direct Known Subclasses:

CdcRecordChannelComputer

public abstract class CdcFixedBucketChannelComputerBase<T>
extends Object
implements ChannelComputer<T>

ChannelComputer for distributing CDC records into writers for fixed-bucket mode tables.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected TableSchema	schema

Constructor Summary

Constructors

Constructor and Description
CdcFixedBucketChannelComputerBase(TableSchema schema)

Method Summary

Modifier and Type	Method and Description
int	channel(T record)
protected abstract KeyAndBucketExtractor<T>	createExtractor()
void	setup(int numChannels)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.paimon.table.sink.ChannelComputer

select, select, transform

Field Detail

schema

protected final TableSchema schema

Constructor Detail

CdcFixedBucketChannelComputerBase

public CdcFixedBucketChannelComputerBase(TableSchema schema)

Method Detail

setup

public void setup(int numChannels)

Specified by:

setup in interface ChannelComputer<T>

createExtractor

protected abstract KeyAndBucketExtractor<T> createExtractor()

channel

public int channel(T record)

Specified by:

channel in interface ChannelComputer<T>

toString

public String toString()

Overrides:

toString in class Object