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

Interface FlinkSinkFunctionProvider

All Superinterfaces:

EventSinkProvider

@PublicEvolving
public interface FlinkSinkFunctionProvider
extends EventSinkProvider

FlinkSinkFunctionProvider is used to provide a Flink SinkFunction for writing events to external systems.

Method Summary

Modifier and Type	Method	Description
org.apache.flink.streaming.api.functions.sink.SinkFunction<Event>	getSinkFunction()	Get the SinkFunction for writing events to external systems.
static FlinkSinkFunctionProvider	of(org.apache.flink.streaming.api.functions.sink.SinkFunction<Event> sinkFunction)	Create a FlinkSinkFunctionProvider from a SinkFunction.

Method Detail

getSinkFunction

org.apache.flink.streaming.api.functions.sink.SinkFunction<Event> getSinkFunction()

Get the SinkFunction for writing events to external systems.

of

static FlinkSinkFunctionProvider of(org.apache.flink.streaming.api.functions.sink.SinkFunction<Event> sinkFunction)

Create a FlinkSinkFunctionProvider from a SinkFunction.