Package org.apache.flink.cdc.common.source.discover

Interface TableDiscovererFactory

All Superinterfaces:

ObjectIdDiscovererFactory<TableId>

All Known Implementing Classes:

FlussDefaultDiscovererFactory, JdbcTableDiscovererFactory

@PublicEvolving
public interface TableDiscovererFactory
extends ObjectIdDiscovererFactory<TableId>

Table-specific SPI factory that creates a TableDiscoverer.

Nested Class Summary

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

ObjectIdDiscovererFactory.DefaultObjectIdDiscovererContext

Method Summary

Modifier and Type	Method	Description
static ObjectIdDiscoverer.Context	createContext(Configuration configuration, ClassLoader classLoader)	Creates a discoverer context with the given configuration and class loader.
TableDiscoverer	createDiscoverer()	Creates a new uninitialized TableDiscoverer.
static TableDiscoverer	createDiscoverer(String type, ClassLoader classLoader)	Discovers a table discoverer factory via SPI and delegates discoverer creation to it.
default Class<TableId>	objectIdClass()	Compatibility alias for the old single identifier, now meaning storage-side type.

Methods inherited from interface org.apache.flink.cdc.common.source.discover.ObjectIdDiscovererFactory

type

Method Detail

objectIdClass

default Class<TableId> objectIdClass()

Compatibility alias for the old single identifier, now meaning storage-side type.

Specified by:

objectIdClass in interface ObjectIdDiscovererFactory<TableId>

createDiscoverer

TableDiscoverer createDiscoverer()

Creates a new uninitialized TableDiscoverer.

Specified by:

createDiscoverer in interface ObjectIdDiscovererFactory<TableId>

createContext

static ObjectIdDiscoverer.Context createContext(Configuration configuration,
                                                ClassLoader classLoader)

Creates a discoverer context with the given configuration and class loader.

createDiscoverer

static TableDiscoverer createDiscoverer(String type,
                                        ClassLoader classLoader)

Discovers a table discoverer factory via SPI and delegates discoverer creation to it.