Package org.apache.flink.table.connector.sink.legacy

Interface SinkFunctionProvider

All Superinterfaces:

DynamicTableSink.SinkRuntimeProvider, ParallelismProvider

@Internal
public interface SinkFunctionProvider
extends DynamicTableSink.SinkRuntimeProvider, ParallelismProvider

Deprecated.

This interface is based on the SinkFunction API, which is due to be removed. Use SinkV2Provider instead.

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

Method Summary

Modifier and Type	Method	Description
SinkFunction<RowData>	createSinkFunction()	Deprecated. Creates a SinkFunction instance.
static SinkFunctionProvider	of(SinkFunction<RowData> sinkFunction)	Deprecated. Helper method for creating a static provider.
static SinkFunctionProvider	of(SinkFunction<RowData> sinkFunction, Integer sinkParallelism)	Deprecated. 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)

Deprecated.

Helper method for creating a static provider.

of

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

Deprecated.

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

createSinkFunction

SinkFunction<RowData> createSinkFunction()

Deprecated.

Creates a SinkFunction instance.