Package org.apache.flink.cdc.common.sink

Interface FlinkSinkProvider

All Superinterfaces:

EventSinkProvider

@PublicEvolving
public interface FlinkSinkProvider
extends EventSinkProvider

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

Method Summary

Modifier and Type	Method	Description
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.

Method Detail

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.