org.apache.paimon.flink.sink

Class DynamicBucketCompactSink

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

org.apache.paimon.flink.sink.DynamicBucketCompactSink

All Implemented Interfaces:

Serializable

public class DynamicBucketCompactSink
extends RowDynamicBucketSink

This class is only used for generate compact sink topology 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
DynamicBucketCompactSink(FileStoreTable table, Map<String,String> overwritePartition)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.streaming.api.datastream.DataStreamSink<?>	build(org.apache.flink.streaming.api.datastream.DataStream<InternalRow> input, Integer parallelism)

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

assignerChannelComputer, channelComputer2, createWriteOperator, extractorFunction

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

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

DynamicBucketCompactSink

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

Method Detail

build

public org.apache.flink.streaming.api.datastream.DataStreamSink<?> build(org.apache.flink.streaming.api.datastream.DataStream<InternalRow> input,
                                                                         @Nullable
                                                                         Integer parallelism)

Overrides:

build in class DynamicBucketSink<InternalRow>