org.apache.flink.cdc.common.source

接口 FlinkSourceProvider

所有超级接口:

EventSourceProvider

@PublicEvolving
public interface FlinkSourceProvider
extends EventSourceProvider

FlinkSourceProvider is used to provide a Flink Source for reading events from external systems.

方法概要

限定符和类型	方法和说明
org.apache.flink.api.connector.source.Source<Event,?,?>	getSource() Get the Source for reading events from external systems.
static FlinkSourceProvider	of(org.apache.flink.api.connector.source.Source<Event,?,?> source) Create a FlinkSourceProvider from a Source.

方法详细资料

getSource

org.apache.flink.api.connector.source.Source<Event,?,?> getSource()

Get the Source for reading events from external systems.

of

static FlinkSourceProvider of(org.apache.flink.api.connector.source.Source<Event,?,?> source)

Create a FlinkSourceProvider from a Source.