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

Class JdbcTableDiscovererFactory

java.lang.Object

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

All Implemented Interfaces:

ObjectIdDiscovererFactory<TableId>, TableDiscovererFactory

public class JdbcTableDiscovererFactory
extends Object
implements TableDiscovererFactory

TableDiscovererFactory for JdbcTableDiscoverer with factory type jdbc.

Nested Class Summary

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

ObjectIdDiscovererFactory.DefaultObjectIdDiscovererContext

Field Summary

Fields

Modifier and Type	Field	Description
static String	TYPE

Constructor Summary

Constructors

Constructor	Description
JdbcTableDiscovererFactory()

Method Summary

Modifier and Type	Method	Description
TableDiscoverer	createDiscoverer()	Creates a new uninitialized TableDiscoverer.
String	type()	Storage-side type, such as jdbc, local-file, or remote-store.

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

objectIdClass

Field Detail

TYPE

public static final String TYPE

See Also:

Constant Field Values

Constructor Detail

JdbcTableDiscovererFactory

public JdbcTableDiscovererFactory()

Method Detail

type

public String type()

Description copied from interface: ObjectIdDiscovererFactory

Storage-side type, such as jdbc, local-file, or remote-store.

Specified by:

type in interface ObjectIdDiscovererFactory<TableId>

createDiscoverer

public TableDiscoverer createDiscoverer()

Description copied from interface: TableDiscovererFactory

Creates a new uninitialized TableDiscoverer.

Specified by:

createDiscoverer in interface ObjectIdDiscovererFactory<TableId>

Specified by:

createDiscoverer in interface TableDiscovererFactory