org.apache.flink.cdc.common.sink

接口 FlinkSinkFunctionProvider

所有超级接口:

EventSinkProvider

@PublicEvolving
public interface FlinkSinkFunctionProvider
extends EventSinkProvider

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

方法概要

限定符和类型	方法和说明
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.

方法详细资料

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.