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

Class SqlServerDataSource

java.lang.Object

org.apache.flink.cdc.connectors.sqlserver.source.SqlServerDataSource

All Implemented Interfaces:

DataSource

@Internal
public class SqlServerDataSource
extends Object
implements DataSource

A DataSource for SQL Server CDC connector.

Constructor Summary

Constructors

Constructor	Description
SqlServerDataSource(SqlServerSourceConfigFactory configFactory)
SqlServerDataSource(SqlServerSourceConfigFactory configFactory, List<SqlServerReadableMetadata> 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.
SqlServerSourceConfig	getSqlServerSourceConfig()
boolean	isParallelMetadataSource()	Indicating if this source may generate metadata events (SchemaChangeEvents) in parallel for each table.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.cdc.common.source.DataSource

supportedMetadataColumns

Constructor Detail

SqlServerDataSource

public SqlServerDataSource(SqlServerSourceConfigFactory configFactory)

SqlServerDataSource

public SqlServerDataSource(SqlServerSourceConfigFactory configFactory,
                           List<SqlServerReadableMetadata> 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

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

getSqlServerSourceConfig

@VisibleForTesting
public SqlServerSourceConfig getSqlServerSourceConfig()