Uses of Interface
org.apache.flink.cdc.common.source.discover.TableDiscoverer

Packages that use TableDiscoverer

Package	Description
org.apache.flink.cdc.common.source.discover
org.apache.flink.cdc.connectors.fluss.source
org.apache.flink.cdc.connectors.fluss.source.discover
org.apache.flink.cdc.connectors.fluss.source.enumerator

Uses of TableDiscoverer in org.apache.flink.cdc.common.source.discover

Classes in org.apache.flink.cdc.common.source.discover that implement TableDiscoverer

Modifier and Type	Class	Description
class	JdbcTableDiscoverer	A TableDiscoverer that reads the list of subscribed tables from a JDBC database.

Methods in org.apache.flink.cdc.common.source.discover that return TableDiscoverer

Modifier and Type	Method	Description
TableDiscoverer	JdbcTableDiscovererFactory.createDiscoverer()
TableDiscoverer	TableDiscovererFactory.createDiscoverer()	Creates a new uninitialized TableDiscoverer.
static TableDiscoverer	TableDiscovererFactory.createDiscoverer(String type, ClassLoader classLoader)	Discovers a table discoverer factory via SPI and delegates discoverer creation to it.

Uses of TableDiscoverer in org.apache.flink.cdc.connectors.fluss.source

Constructors in org.apache.flink.cdc.connectors.fluss.source with parameters of type TableDiscoverer

Constructor	Description
FlussDataSource(org.apache.fluss.config.Configuration flussConfig, Configuration sourceConfig, TableDiscoverer discoverer, org.apache.fluss.client.initializer.OffsetsInitializer offsetsInitializer, long scanDiscoveryIntervalMs)
FlussSource(TableDiscoverer discoverer, org.apache.fluss.config.Configuration flussConfig, Configuration sourceConfig, org.apache.fluss.client.initializer.OffsetsInitializer offsetsInitializer, long scanDiscoveryIntervalMs, FlussDeserializer<T> deserializer)

Uses of TableDiscoverer in org.apache.flink.cdc.connectors.fluss.source.discover

Classes in org.apache.flink.cdc.connectors.fluss.source.discover that implement TableDiscoverer

Modifier and Type	Class	Description
class	FlussDefaultDiscoverer	The default TableDiscoverer for Fluss that subscribes to tables whose fully-qualified name (formatted as "database.tableName") matches a user-provided Java regular expression.

Methods in org.apache.flink.cdc.connectors.fluss.source.discover that return TableDiscoverer

Modifier and Type	Method	Description
TableDiscoverer	FlussDefaultDiscovererFactory.createDiscoverer()

Uses of TableDiscoverer in org.apache.flink.cdc.connectors.fluss.source.enumerator

Constructors in org.apache.flink.cdc.connectors.fluss.source.enumerator with parameters of type TableDiscoverer

Constructor	Description
FlussSourceEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FlussSplitBase> context, TableDiscoverer discoverer, org.apache.fluss.config.Configuration flussConfig, Configuration sourceConfig, org.apache.fluss.client.initializer.OffsetsInitializer offsetsInitializer, long scanDiscoveryIntervalMs, Set<org.apache.fluss.metadata.PhysicalTablePath> assignedPhysicalTablePaths, List<FlussSplitBase> remainingSplits, LeaseContext leaseContext, boolean checkpointCompletedBefore)
FlussSourceEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FlussSplitBase> context, TableDiscoverer discoverer, org.apache.fluss.config.Configuration flussConfig, Configuration sourceConfig, org.apache.fluss.client.initializer.OffsetsInitializer offsetsInitializer, long scanDiscoveryIntervalMs, FlussSourceEnumState restoredState, LeaseContext leaseContext)