@FunctionalInterface public static interface StoreSinkWrite.Provider extends Serializable
StoreSinkWrite
.Modifier and Type | Method and Description |
---|---|
StoreSinkWrite |
provide(FileStoreTable table,
String commitUser,
StoreSinkWriteState state,
org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager,
MemorySegmentPool memoryPool,
org.apache.flink.metrics.MetricGroup metricGroup)
TODO: The argument list has become too complicated.
|
StoreSinkWrite provide(FileStoreTable table, String commitUser, StoreSinkWriteState state, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, @Nullable MemorySegmentPool memoryPool, @Nullable org.apache.flink.metrics.MetricGroup metricGroup)
TableWriteImpl
directly
in caller and simplify the argument list.Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.