org.apache.flink.cdc.common.source

接口 DataSource

@PublicEvolving
public interface DataSource

DataSource is used to access metadata and read change data from external systems. It can read data from multiple tables simultaneously.

方法概要

限定符和类型	方法和说明
EventSourceProvider	getEventSourceProvider() Get the EventSourceProvider for reading events from external systems.
MetadataAccessor	getMetadataAccessor() Get the MetadataAccessor for accessing metadata from external systems.
default boolean	isParallelMetadataSource() Indicating if this source may generate metadata events (SchemaChangeEvents) in parallel for each table.
default SupportedMetadataColumn[]	supportedMetadataColumns() Get the SupportedMetadataColumns of the source.

方法详细资料

getEventSourceProvider

EventSourceProvider getEventSourceProvider()

Get the EventSourceProvider for reading events from external systems.

getMetadataAccessor

MetadataAccessor getMetadataAccessor()

Get the MetadataAccessor for accessing metadata from external systems.

supportedMetadataColumns

default SupportedMetadataColumn[] supportedMetadataColumns()

Get the SupportedMetadataColumns of the source.

isParallelMetadataSource

@Experimental
default boolean isParallelMetadataSource()

Indicating if this source may generate metadata events (SchemaChangeEvents) in parallel for each table. If returns false, you'll get a regular operator topology that is compatible with single-incremented sources like MySQL. Returns true for sources that does not maintain a globally sequential schema change events stream, like MongoDB or Kafka.
Note that new topology still an experimental feature. Return false by default to avoid unexpected behaviors.