org.apache.paimon.flink.sink

Class RowUnawareBucketSink

java.lang.Object

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

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

org.apache.paimon.flink.sink.UnawareBucketSink<InternalRow>

org.apache.paimon.flink.sink.RowUnawareBucketSink

All Implemented Interfaces:

Serializable

public class RowUnawareBucketSink
extends UnawareBucketSink<InternalRow>

An UnawareBucketSink which handles InternalRow.

See Also:

Serialized Form

Field Summary

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

logSinkFunction, parallelism, table

Constructor Summary

Constructors

Constructor and Description
RowUnawareBucketSink(FileStoreTable table, Map<String,String> overwritePartitions, LogSinkFunction logSinkFunction, Integer parallelism)

Method Summary

Modifier and Type	Method and Description
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<InternalRow,Committable>	createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)

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

doWrite

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

Methods inherited from class java.lang.Object

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

Constructor Detail

RowUnawareBucketSink

public RowUnawareBucketSink(FileStoreTable table,
                            Map<String,String> overwritePartitions,
                            LogSinkFunction logSinkFunction,
                            Integer parallelism)

Method Detail

createWriteOperator

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

Specified by:

createWriteOperator in class FlinkSink<InternalRow>