org.apache.paimon.flink.sink.cdc

Class CdcPostponeBucketChannelComputer

java.lang.Object

org.apache.paimon.flink.sink.cdc.CdcPostponeBucketChannelComputer

All Implemented Interfaces:

Serializable, ChannelComputer<CdcRecord>

public class CdcPostponeBucketChannelComputer
extends Object
implements ChannelComputer<CdcRecord>

ChannelComputer for writing CdcRecords into postpone bucket tables. Records with same primary keys are distributed to the same subtask.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CdcPostponeBucketChannelComputer(TableSchema schema)

Method Summary

Modifier and Type	Method and Description
int	channel(CdcRecord record)
void	setup(int numChannels)

Methods inherited from class java.lang.Object

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

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

select, select, startChannel, transform

Constructor Detail

CdcPostponeBucketChannelComputer

public CdcPostponeBucketChannelComputer(TableSchema schema)

Method Detail

setup

public void setup(int numChannels)

Specified by:

setup in interface ChannelComputer<CdcRecord>

channel

public int channel(CdcRecord record)

Specified by:

channel in interface ChannelComputer<CdcRecord>