Package org.apache.flink.cdc.connectors.mysql.source

Class MySqlDataSource

java.lang.Object

org.apache.flink.cdc.connectors.mysql.source.MySqlDataSource

All Implemented Interfaces:

DataSource

@Internal
public class MySqlDataSource
extends Object
implements DataSource

A DataSource for mysql cdc connector.

Constructor Summary

Constructors

Constructor	Description
MySqlDataSource(MySqlSourceConfigFactory configFactory)
MySqlDataSource(MySqlSourceConfigFactory configFactory, List<MySqlReadableMetadata> readableMetadataList)

Method Summary

Modifier and Type	Method	Description
EventSourceProvider	getEventSourceProvider()	Get the EventSourceProvider for reading events from external systems.
MetadataAccessor	getMetadataAccessor()	Get the MetadataAccessor for accessing metadata from external systems.
MySqlSourceConfig	getSourceConfig()
boolean	isParallelMetadataSource()	Indicating if this source may generate metadata events (SchemaChangeEvents) in parallel for each table.
SupportedMetadataColumn[]	supportedMetadataColumns()	Get the SupportedMetadataColumns of the source.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MySqlDataSource

public MySqlDataSource(MySqlSourceConfigFactory configFactory)

MySqlDataSource

public MySqlDataSource(MySqlSourceConfigFactory configFactory,
                       List<MySqlReadableMetadata> readableMetadataList)

Method Detail

getEventSourceProvider

public EventSourceProvider getEventSourceProvider()

Description copied from interface: DataSource

Get the EventSourceProvider for reading events from external systems.

Specified by:

getEventSourceProvider in interface DataSource

getMetadataAccessor

public MetadataAccessor getMetadataAccessor()

Description copied from interface: DataSource

Get the MetadataAccessor for accessing metadata from external systems.

Specified by:

getMetadataAccessor in interface DataSource

getSourceConfig

@VisibleForTesting
public MySqlSourceConfig getSourceConfig()

supportedMetadataColumns

public SupportedMetadataColumn[] supportedMetadataColumns()

Description copied from interface: DataSource

Get the SupportedMetadataColumns of the source.

Specified by:

supportedMetadataColumns in interface DataSource

isParallelMetadataSource

public boolean isParallelMetadataSource()

Description copied from interface: DataSource

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.

Specified by:

isParallelMetadataSource in interface DataSource