public class RewriteFileIndexSink extends FlinkWriteSink<ManifestEntry>
RewriteFileIndexProcedure
.Modifier and Type | Class and Description |
---|---|
static class |
RewriteFileIndexSink.FileIndexProcessor
Does the file index rewrite.
|
Constructor and Description |
---|
RewriteFileIndexSink(FileStoreTable table) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<ManifestEntry,Committable> |
createWriteOperator(StoreSinkWrite.Provider writeProvider,
String commitUser) |
createCommittableStateManager, createCommitterFactory
assertBatchAdaptiveParallelism, assertBatchAdaptiveParallelism, assertStreamingConfiguration, configureGlobalCommitter, doCommit, doWrite, isStreaming, isStreaming, sinkFrom, sinkFrom
public RewriteFileIndexSink(FileStoreTable table)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<ManifestEntry,Committable> createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
createWriteOperator
in class FlinkSink<ManifestEntry>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.