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

Interface FlinkSourceProvider

All Superinterfaces:

EventSourceProvider

@PublicEvolving
public interface FlinkSourceProvider
extends EventSourceProvider

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

Method Summary

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

Method Detail

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.