org.apache.paimon.flink.sink

Class RowDynamicBucketSink

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<InternalRow>

org.apache.paimon.flink.sink.RowDynamicBucketSink

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

DynamicBucketCompactSink

public class RowDynamicBucketSink
extends DynamicBucketSink<InternalRow>

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
RowDynamicBucketSink(FileStoreTable table, Map<String,String> overwritePartition)

Method Summary

Modifier and Type	Method and Description
protected ChannelComputer<InternalRow>	assignerChannelComputer(Integer numAssigners)
protected ChannelComputer<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>>	channelComputer2()
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>,Committable>	createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
protected SerializableFunction<TableSchema,PartitionKeyExtractor<InternalRow>>	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, assertBatchAdaptiveParallelism, assertStreamingConfiguration, configureGlobalCommitter, 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

RowDynamicBucketSink

public RowDynamicBucketSink(FileStoreTable table,
                            @Nullable
                            Map<String,String> overwritePartition)

Method Detail

assignerChannelComputer

protected ChannelComputer<InternalRow> assignerChannelComputer(Integer numAssigners)

Specified by:

assignerChannelComputer in class DynamicBucketSink<InternalRow>

channelComputer2

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

Specified by:

channelComputer2 in class DynamicBucketSink<InternalRow>

extractorFunction

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

Specified by:

extractorFunction in class DynamicBucketSink<InternalRow>

createWriteOperator

protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>,Committable> createWriteOperator(StoreSinkWrite.Provider writeProvider,
                                                                                                                                                                       String commitUser)

Specified by:

createWriteOperator in class FlinkSink<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>>