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

Interface SinkV2Provider

All Superinterfaces:

DynamicTableSink.SinkRuntimeProvider, ParallelismProvider

@PublicEvolving
public interface SinkV2Provider
extends DynamicTableSink.SinkRuntimeProvider, ParallelismProvider

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.sink2.Sink<RowData>	createSink()
default Map<String,String>	getAdditionalMetricVariables()
static SinkV2Provider	of(org.apache.flink.api.connector.sink2.Sink<RowData> sink)	Helper method for creating a static provider.
static SinkV2Provider	of(org.apache.flink.api.connector.sink2.Sink<RowData> sink, Integer sinkParallelism)	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 SinkV2Provider of(org.apache.flink.api.connector.sink2.Sink<RowData> sink)

Helper method for creating a static provider.

of

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

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

createSink

org.apache.flink.api.connector.sink2.Sink<RowData> createSink()

getAdditionalMetricVariables

default Map<String,String> getAdditionalMetricVariables()

Returns:

additional variables that will be added to scope of the metrics reported from the Sink created by this SinkV2Provider.