org.apache.flink.cdc.common.source

接口 FlinkSourceFunctionProvider

所有超级接口:

EventSourceProvider

@PublicEvolving
public interface FlinkSourceFunctionProvider
extends EventSourceProvider

FlinkSourceFunctionProvider is used to provide a Flink SourceFunction for reading events from external systems.

方法概要

限定符和类型	方法和说明
org.apache.flink.streaming.api.functions.source.SourceFunction<Event>	getSourceFunction() Get the SourceFunction for reading events from external systems.
static FlinkSourceFunctionProvider	of(org.apache.flink.streaming.api.functions.source.SourceFunction<Event> sourceFunction) Create a FlinkSourceFunctionProvider from a SourceFunction.

方法详细资料

getSourceFunction

org.apache.flink.streaming.api.functions.source.SourceFunction<Event> getSourceFunction()

Get the SourceFunction for reading events from external systems.

of

static FlinkSourceFunctionProvider of(org.apache.flink.streaming.api.functions.source.SourceFunction<Event> sourceFunction)

Create a FlinkSourceFunctionProvider from a SourceFunction.