public class DynamicBucketCompactSink extends RowDynamicBucketSink
Constructor and Description |
---|
DynamicBucketCompactSink(FileStoreTable table,
Map<String,String> overwritePartition) |
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) |
assignerChannelComputer, channelComputer2, createWriteOperator, extractorFunction
createHashBucketAssignerOperator
createCommittableStateManager, createCommitterFactory
assertBatchAdaptiveParallelism, assertBatchAdaptiveParallelism, assertStreamingConfiguration, configureGlobalCommitter, doCommit, doWrite, isStreaming, isStreaming, sinkFrom, sinkFrom
public DynamicBucketCompactSink(FileStoreTable table, @Nullable Map<String,String> overwritePartition)
public org.apache.flink.streaming.api.datastream.DataStreamSink<?> build(org.apache.flink.streaming.api.datastream.DataStream<InternalRow> input, @Nullable Integer parallelism)
build
in class DynamicBucketSink<InternalRow>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.