org.apache.paimon.flink.sink.cdc

Class CdcDynamicBucketSinkBase<T>

java.lang.Object

org.apache.paimon.flink.sink.FlinkSink<T>

org.apache.paimon.flink.sink.FlinkWriteSink<org.apache.flink.api.java.tuple.Tuple2<T,Integer>>

org.apache.paimon.flink.sink.DynamicBucketSink<T>

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

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

CdcDynamicBucketSink

public abstract class CdcDynamicBucketSinkBase<T>
extends DynamicBucketSink<T>

CDC sink for dynamic bucket table.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.paimon.flink.sink.FlinkSink

table

Constructor Summary

Constructors

Constructor and Description
CdcDynamicBucketSinkBase(FileStoreTable table)

Method Summary

Modifier and Type	Method and Description
protected ChannelComputer<T>	assignerChannelComputer(Integer numAssigners)
protected ChannelComputer<org.apache.flink.api.java.tuple.Tuple2<T,Integer>>	channelComputer2()
protected abstract KeyAndBucketExtractor<T>	createExtractor(TableSchema schema)
protected SerializableFunction<TableSchema,PartitionKeyExtractor<T>>	extractorFunction()

Methods inherited from class org.apache.paimon.flink.sink.DynamicBucketSink

build, createHashBucketAssignerOperator

Methods inherited from class org.apache.paimon.flink.sink.FlinkWriteSink

createCommittableStateManager, createCommitterFactory

Methods inherited from class org.apache.paimon.flink.sink.FlinkSink

assertBatchAdaptiveParallelism, assertBatchAdaptiveParallelism, assertStreamingConfiguration, configureGlobalCommitter, createWriteOperator, doCommit, doWrite, isStreaming, isStreaming, sinkFrom, sinkFrom

Methods inherited from class java.lang.Object

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

Constructor Detail

CdcDynamicBucketSinkBase

public CdcDynamicBucketSinkBase(FileStoreTable table)

Method Detail

assignerChannelComputer

protected ChannelComputer<T> assignerChannelComputer(Integer numAssigners)

Specified by:

assignerChannelComputer in class DynamicBucketSink<T>

channelComputer2

protected ChannelComputer<org.apache.flink.api.java.tuple.Tuple2<T,Integer>> channelComputer2()

Specified by:

channelComputer2 in class DynamicBucketSink<T>

extractorFunction

protected SerializableFunction<TableSchema,PartitionKeyExtractor<T>> extractorFunction()

Specified by:

extractorFunction in class DynamicBucketSink<T>

createExtractor

protected abstract KeyAndBucketExtractor<T> createExtractor(TableSchema schema)