public class AsyncLookupSinkWrite extends StoreSinkWriteImpl
StoreSinkWrite
for tables with lookup changelog producer and CoreOptions.LOOKUP_WAIT
set to false.StoreSinkWrite.Provider, StoreSinkWrite.WithWriteBufferProvider
commitUser, state, write
Constructor and Description |
---|
AsyncLookupSinkWrite(FileStoreTable table,
String commitUser,
StoreSinkWriteState state,
org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager,
boolean ignorePreviousFiles,
boolean waitCompaction,
boolean isStreaming,
MemorySegmentPool memoryPool,
org.apache.flink.metrics.MetricGroup metricGroup) |
Modifier and Type | Method and Description |
---|---|
void |
snapshotState() |
close, compact, getWrite, notifyNewFiles, prepareCommit, replace, streamingMode, toLogRecord, withCompactExecutor, withInsertOnly, write, write
public AsyncLookupSinkWrite(FileStoreTable table, String commitUser, StoreSinkWriteState state, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, boolean ignorePreviousFiles, boolean waitCompaction, boolean isStreaming, @Nullable MemorySegmentPool memoryPool, org.apache.flink.metrics.MetricGroup metricGroup)
public void snapshotState() throws Exception
snapshotState
in interface StoreSinkWrite
snapshotState
in class StoreSinkWriteImpl
Exception
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.