public class CompactorSink extends FlinkSink
FlinkSink
for dedicated compact jobs.Constructor and Description |
---|
CompactorSink(FileStoreTable table,
Lock.Factory lockFactory) |
Modifier and Type | Method and Description |
---|---|
protected CommittableStateManager |
createCommittableStateManager() |
protected org.apache.flink.util.function.SerializableFunction<String,Committer> |
createCommitterFactory(boolean streamingCheckpointEnabled) |
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.table.data.RowData,Committable> |
createWriteOperator(StoreSinkWrite.Provider writeProvider,
boolean isStreaming) |
createWriteProvider, sinkFrom
public CompactorSink(FileStoreTable table, Lock.Factory lockFactory)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.table.data.RowData,Committable> createWriteOperator(StoreSinkWrite.Provider writeProvider, boolean isStreaming)
createWriteOperator
in class FlinkSink
protected org.apache.flink.util.function.SerializableFunction<String,Committer> createCommitterFactory(boolean streamingCheckpointEnabled)
createCommitterFactory
in class FlinkSink
protected CommittableStateManager createCommittableStateManager()
createCommittableStateManager
in class FlinkSink
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.