public abstract class FlinkSink extends Object implements Serializable
Modifier and Type | Field and Description |
---|---|
protected FileStoreTable |
table |
Constructor and Description |
---|
FlinkSink(FileStoreTable table,
boolean isOverwrite) |
Modifier and Type | Method and Description |
---|---|
protected abstract CommittableStateManager |
createCommittableStateManager() |
protected abstract org.apache.flink.util.function.SerializableFunction<String,Committer> |
createCommitterFactory(boolean streamingCheckpointEnabled) |
protected abstract org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.table.data.RowData,Committable> |
createWriteOperator(StoreSinkWrite.Provider writeProvider,
boolean isStreaming) |
protected StoreSinkWrite.Provider |
createWriteProvider(String initialCommitUser) |
org.apache.flink.streaming.api.datastream.DataStreamSink<?> |
sinkFrom(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> input) |
protected final FileStoreTable table
public FlinkSink(FileStoreTable table, boolean isOverwrite)
protected StoreSinkWrite.Provider createWriteProvider(String initialCommitUser)
public org.apache.flink.streaming.api.datastream.DataStreamSink<?> sinkFrom(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> input)
protected abstract org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.table.data.RowData,Committable> createWriteOperator(StoreSinkWrite.Provider writeProvider, boolean isStreaming)
protected abstract org.apache.flink.util.function.SerializableFunction<String,Committer> createCommitterFactory(boolean streamingCheckpointEnabled)
protected abstract CommittableStateManager createCommittableStateManager()
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.