public class UnawareBucketCompactionSink extends FlinkSink<UnawareAppendCompactionTask>
Constructor and Description |
---|
UnawareBucketCompactionSink(FileStoreTable table) |
Modifier and Type | Method and Description |
---|---|
protected CommittableStateManager<ManifestCommittable> |
createCommittableStateManager() |
protected Committer.Factory<Committable,ManifestCommittable> |
createCommitterFactory() |
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<UnawareAppendCompactionTask,Committable> |
createWriteOperator(StoreSinkWrite.Provider writeProvider,
String commitUser) |
static org.apache.flink.streaming.api.datastream.DataStreamSink<?> |
sink(FileStoreTable table,
org.apache.flink.streaming.api.datastream.DataStream<UnawareAppendCompactionTask> input) |
assertBatchAdaptiveParallelism, assertBatchAdaptiveParallelism, assertStreamingConfiguration, configureGlobalCommitter, doCommit, doWrite, isStreaming, isStreaming, sinkFrom, sinkFrom
public UnawareBucketCompactionSink(FileStoreTable table)
public static org.apache.flink.streaming.api.datastream.DataStreamSink<?> sink(FileStoreTable table, org.apache.flink.streaming.api.datastream.DataStream<UnawareAppendCompactionTask> input)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<UnawareAppendCompactionTask,Committable> createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
createWriteOperator
in class FlinkSink<UnawareAppendCompactionTask>
protected Committer.Factory<Committable,ManifestCommittable> createCommitterFactory()
createCommitterFactory
in class FlinkSink<UnawareAppendCompactionTask>
protected CommittableStateManager<ManifestCommittable> createCommittableStateManager()
createCommittableStateManager
in class FlinkSink<UnawareAppendCompactionTask>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.