org.apache.flink.table.connector.sink

Interface SinkFunctionProvider

All Superinterfaces:

DynamicTableSink.SinkRuntimeProvider, ParallelismProvider

@PublicEvolving
public interface SinkFunctionProvider
extends DynamicTableSink.SinkRuntimeProvider, ParallelismProvider

Provider of a SinkFunction instance as a runtime implementation for DynamicTableSink.

Method Summary

Modifier and Type	Method and Description
SinkFunction<RowData>	createSinkFunction() Creates a SinkFunction instance.
static SinkFunctionProvider	of(SinkFunction<RowData> sinkFunction) Helper method for creating a static provider.
static SinkFunctionProvider	of(SinkFunction<RowData> sinkFunction, Integer sinkParallelism) Helper method for creating a SinkFunction provider with a provided sink parallelism.

Methods inherited from interface org.apache.flink.table.connector.ParallelismProvider

getParallelism

Method Detail

of

static SinkFunctionProvider of(SinkFunction<RowData> sinkFunction)

Helper method for creating a static provider.

of

static SinkFunctionProvider of(SinkFunction<RowData> sinkFunction,
                               Integer sinkParallelism)

Helper method for creating a SinkFunction provider with a provided sink parallelism.

createSinkFunction

SinkFunction<RowData> createSinkFunction()

Creates a SinkFunction instance.