org.apache.paimon.flink.sink.cdc

Class CdcRecordChannelComputer

java.lang.Object

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

org.apache.paimon.flink.sink.cdc.CdcRecordChannelComputer

All Implemented Interfaces:

Serializable, ChannelComputer<CdcRecord>

public class CdcRecordChannelComputer
extends CdcFixedBucketChannelComputerBase<CdcRecord>

CdcFixedBucketChannelComputerBase for CdcRecord.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.paimon.flink.sink.cdc.CdcFixedBucketChannelComputerBase

schema

Constructor Summary

Constructors

Constructor and Description
CdcRecordChannelComputer(TableSchema schema)

Method Summary

Modifier and Type	Method and Description
protected KeyAndBucketExtractor<CdcRecord>	createExtractor()

Methods inherited from class org.apache.paimon.flink.sink.cdc.CdcFixedBucketChannelComputerBase

channel, setup, 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

Constructor Detail

CdcRecordChannelComputer

public CdcRecordChannelComputer(TableSchema schema)

Method Detail

createExtractor

protected KeyAndBucketExtractor<CdcRecord> createExtractor()

Specified by:

createExtractor in class CdcFixedBucketChannelComputerBase<CdcRecord>