public class RowDynamicBucketSink extends DynamicBucketSink<InternalRow>
Constructor and Description |
---|
RowDynamicBucketSink(FileStoreTable table,
Map<String,String> overwritePartition) |
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() |
build, createHashBucketAssignerOperator
createCommittableStateManager, createCommitterFactory
assertBatchAdaptiveParallelism, assertBatchAdaptiveParallelism, assertStreamingConfiguration, configureGlobalCommitter, doCommit, doWrite, isStreaming, isStreaming, sinkFrom, sinkFrom
public RowDynamicBucketSink(FileStoreTable table, @Nullable Map<String,String> overwritePartition)
protected ChannelComputer<InternalRow> assignerChannelComputer(Integer numAssigners)
assignerChannelComputer
in class DynamicBucketSink<InternalRow>
protected ChannelComputer<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>> channelComputer2()
channelComputer2
in class DynamicBucketSink<InternalRow>
protected SerializableFunction<TableSchema,PartitionKeyExtractor<InternalRow>> extractorFunction()
extractorFunction
in class DynamicBucketSink<InternalRow>
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>,Committable> createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
createWriteOperator
in class FlinkSink<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.