org.apache.flink.cdc.common.sink

接口 FlinkSinkProvider

所有超级接口:

EventSinkProvider

@PublicEvolving
public interface FlinkSinkProvider
extends EventSinkProvider

FlinkSinkProvider is used to provide a Flink Sink for writing events to external systems.

方法概要

限定符和类型	方法和说明
org.apache.flink.api.connector.sink2.Sink<Event>	getSink() Get the Sink for writing events to external systems.
static FlinkSinkProvider	of(org.apache.flink.api.connector.sink2.Sink<Event> sink) Create a FlinkSinkProvider from a Sink.

方法详细资料

getSink

org.apache.flink.api.connector.sink2.Sink<Event> getSink()

Get the Sink for writing events to external systems.

of

static FlinkSinkProvider of(org.apache.flink.api.connector.sink2.Sink<Event> sink)

Create a FlinkSinkProvider from a Sink.