Interface DataSource
-
- All Known Implementing Classes:
FlussDataSource,MySqlDataSource,OracleDataSource,PostgresDataSource,SqlServerDataSource,ValuesDataSource
@PublicEvolving public interface DataSource
DataSourceis used to access metadata and read change data from external systems. It can read data from multiple tables simultaneously.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description EventSourceProvidergetEventSourceProvider()Get theEventSourceProviderfor reading events from external systems.MetadataAccessorgetMetadataAccessor()Get theMetadataAccessorfor accessing metadata from external systems.default booleanisParallelMetadataSource()Indicating if this source may generate metadata events (SchemaChangeEvents) in parallel for each table.default SupportedMetadataColumn[]supportedMetadataColumns()Get theSupportedMetadataColumns of the source.
-
-
-
Method Detail
-
getEventSourceProvider
EventSourceProvider getEventSourceProvider()
Get theEventSourceProviderfor reading events from external systems.
-
getMetadataAccessor
MetadataAccessor getMetadataAccessor()
Get theMetadataAccessorfor accessing metadata from external systems.
-
supportedMetadataColumns
default SupportedMetadataColumn[] supportedMetadataColumns()
Get theSupportedMetadataColumns of the source.
-
isParallelMetadataSource
@Experimental default boolean isParallelMetadataSource()
Indicating if this source may generate metadata events (SchemaChangeEvents) in parallel for each table. If returnsfalse, you'll get a regular operator topology that is compatible with single-incremented sources like MySQL. Returnstruefor sources that does not maintain a globally sequential schema change events stream, like MongoDB or Kafka.
Note that new topology still an experimental feature. Returnfalseby default to avoid unexpected behaviors.
-
-