org.apache.paimon.flink.sink.index

Class GlobalDynamicBucketSink

java.lang.Object

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

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

org.apache.paimon.flink.sink.index.GlobalDynamicBucketSink

All Implemented Interfaces:

Serializable

public class GlobalDynamicBucketSink
extends FlinkWriteSink<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>>

Sink for global 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
GlobalDynamicBucketSink(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)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>,Committable>	createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)

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

GlobalDynamicBucketSink

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

Method Detail

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

build

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