@FunctionalInterface public static interface StoreSinkWrite.WithWriteBufferProvider extends Serializable
StoreSinkWrite
that uses given write buffer.Modifier and Type | Method and Description |
---|---|
StoreSinkWrite |
provide(FileStoreTable table,
String commitUser,
StoreSinkWriteState state,
org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager,
MemoryPoolFactory memoryPoolFactory,
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 MemoryPoolFactory memoryPoolFactory, 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.