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

Class FlussDataSource

java.lang.Object

org.apache.flink.cdc.connectors.fluss.source.FlussDataSource

All Implemented Interfaces:

DataSource

public class FlussDataSource
extends Object
implements DataSource

A CDC-specific DataSource implementation for Fluss. This is the layer where the generic FlussSource is bound to CDC types by providing a FlussRecordDeserializer that produces Event objects.

Constructor Summary

Constructors

Constructor	Description
FlussDataSource(org.apache.fluss.config.Configuration flussConfig, Configuration sourceConfig, TableDiscoverer discoverer, org.apache.fluss.client.initializer.OffsetsInitializer offsetsInitializer, long scanDiscoveryIntervalMs)

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.
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

FlussDataSource

public FlussDataSource(org.apache.fluss.config.Configuration flussConfig,
                       Configuration sourceConfig,
                       TableDiscoverer discoverer,
                       org.apache.fluss.client.initializer.OffsetsInitializer offsetsInitializer,
                       long scanDiscoveryIntervalMs)

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