Package org.apache.flink.cdc.common.source

Interface FlinkSourceFunctionProvider

All Superinterfaces:

EventSourceProvider

@PublicEvolving
public interface FlinkSourceFunctionProvider
extends EventSourceProvider

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

Method Summary

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

Method Detail

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.