public abstract class FlinkWriteSink<T> extends FlinkSink<T>
FlinkSink
to write records.Constructor and Description |
---|
FlinkWriteSink(FileStoreTable table,
Map<String,String> overwritePartition) |
Modifier and Type | Method and Description |
---|---|
protected CommittableStateManager<ManifestCommittable> |
createCommittableStateManager() |
protected Committer.Factory<Committable,ManifestCommittable> |
createCommitterFactory() |
assertBatchAdaptiveParallelism, assertBatchAdaptiveParallelism, assertStreamingConfiguration, configureGlobalCommitter, createWriteOperator, doCommit, doWrite, isStreaming, isStreaming, sinkFrom, sinkFrom
public FlinkWriteSink(FileStoreTable table, @Nullable Map<String,String> overwritePartition)
protected Committer.Factory<Committable,ManifestCommittable> createCommitterFactory()
createCommitterFactory
in class FlinkSink<T>
protected CommittableStateManager<ManifestCommittable> createCommittableStateManager()
createCommittableStateManager
in class FlinkSink<T>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.