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

Interface SinkProvider

All Superinterfaces:

DynamicTableSink.SinkRuntimeProvider, ParallelismProvider

@Deprecated
@PublicEvolving
public interface SinkProvider
extends DynamicTableSink.SinkRuntimeProvider, ParallelismProvider

Deprecated.

Please convert your sink to Sink and use SinkV2Provider.

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

DataStreamSinkProvider in flink-table-api-java-bridge is available for advanced connector developers.

Method Summary

Modifier and Type	Method	Description
org.apache.flink.api.connector.sink.Sink<RowData,?,?,?>	createSink()	Deprecated. Creates a Sink instance.
static SinkProvider	of(org.apache.flink.api.connector.sink.Sink<RowData,?,?,?> sink)	Deprecated. Helper method for creating a static provider.
static SinkProvider	of(org.apache.flink.api.connector.sink.Sink<RowData,?,?,?> sink, Integer sinkParallelism)	Deprecated. Helper method for creating a Sink provider with a provided sink parallelism.

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

getParallelism

Method Detail

of

static SinkProvider of(org.apache.flink.api.connector.sink.Sink<RowData,?,?,?> sink)

Deprecated.

Helper method for creating a static provider.

of

static SinkProvider of(org.apache.flink.api.connector.sink.Sink<RowData,?,?,?> sink,
                       @Nullable
                       Integer sinkParallelism)

Deprecated.

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

createSink

org.apache.flink.api.connector.sink.Sink<RowData,?,?,?> createSink()

Deprecated.

Creates a Sink instance.