org.apache.paimon.flink.sink

Interface StoreSinkWrite.WithWriteBufferProvider

All Superinterfaces:

Serializable

Enclosing interface:

StoreSinkWrite

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public static interface StoreSinkWrite.WithWriteBufferProvider
extends Serializable

Provider of StoreSinkWrite that uses given write buffer.

Method Summary

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.

Method Detail

provide

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)

TODO: The argument list has become too complicated. Build TableWriteImpl directly in caller and simplify the argument list.