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

Class FlussDefaultDiscoverer

java.lang.Object

org.apache.flink.cdc.connectors.fluss.source.discover.FlussDefaultDiscoverer

All Implemented Interfaces:

Serializable, AutoCloseable, ObjectIdDiscoverer<TableId>, TableDiscoverer

public class FlussDefaultDiscoverer
extends Object
implements TableDiscoverer

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

The pattern is matched against the fully-qualified name of every table across every database visible to the Fluss cluster. A single regex can therefore span multiple databases, e.g. "source_db\\..*|audit_db\\.events_.*".

Note: dots in database or table names must be escaped (e.g. "db\\.table") because . is a regex meta-character.

Configuration keys (read from the full connector configuration):

• bootstrap.servers — Fluss bootstrap servers (required).
• table.discoverer.pattern — Java regex for matching fully-qualified table names (required).

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.cdc.common.source.discover.ObjectIdDiscoverer

ObjectIdDiscoverer.Context

Field Summary

Fields

Modifier and Type	Field	Description
static ConfigOption<String>	PATTERN

Constructor Summary

Constructors

Constructor	Description
FlussDefaultDiscoverer()

Method Summary

Modifier and Type	Method	Description
void	close()	Closes this discoverer and releases any resources.
Set<TableId>	discover()	Discovers and returns the complete current set of object identifiers selected by the caller configuration.
void	open(ObjectIdDiscoverer.Context context)	Opens this discoverer and initializes any resources needed for discovery.
static org.apache.fluss.metadata.TablePath	toTablePath(TableId tableId)	Converts a TableId (two-part: schemaName.tableName) to a Fluss TablePath.

Methods inherited from class java.lang.Object

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

Field Detail

PATTERN

public static final ConfigOption<String> PATTERN

Constructor Detail

FlussDefaultDiscoverer

public FlussDefaultDiscoverer()

Method Detail

open

public void open(ObjectIdDiscoverer.Context context)
          throws Exception

Description copied from interface: ObjectIdDiscoverer

Opens this discoverer and initializes any resources needed for discovery.

Specified by:

open in interface ObjectIdDiscoverer<TableId>

Throws:

Exception

discover

public Set<TableId> discover()
                      throws Exception

Description copied from interface: ObjectIdDiscoverer

Discovers and returns the complete current set of object identifiers selected by the caller configuration.

A successful result is authoritative: identifiers absent from it are no longer selected, and an empty result selects no identifiers. A failed discovery does not describe a new set.

Specified by:

discover in interface ObjectIdDiscoverer<TableId>

Throws:

Exception

close

public void close()
           throws Exception

Description copied from interface: ObjectIdDiscoverer

Closes this discoverer and releases any resources.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ObjectIdDiscoverer<TableId>

Throws:

Exception

toTablePath

public static org.apache.fluss.metadata.TablePath toTablePath(TableId tableId)

Converts a TableId (two-part: schemaName.tableName) to a Fluss TablePath.