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

Interface ObjectIdDiscovererFactory<T>

All Known Subinterfaces:

TableDiscovererFactory

All Known Implementing Classes:

FlussDefaultDiscovererFactory, JdbcTableDiscovererFactory

@PublicEvolving
public interface ObjectIdDiscovererFactory<T>

SPI factory that creates an ObjectIdDiscoverer.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	ObjectIdDiscovererFactory.DefaultObjectIdDiscovererContext	Default implementation of ObjectIdDiscoverer.Context.

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.
ObjectIdDiscoverer<T>	createDiscoverer()	Creates a new uninitialized ObjectIdDiscoverer.
static <T> ObjectIdDiscoverer<T>	createDiscoverer(String type, Class<T> objectIdClass, ClassLoader classLoader)	Discovers a factory via SPI and delegates discoverer creation to it.
static <T> ObjectIdDiscovererFactory<T>	discoverFactory(String type, Class<T> objectIdClass, ClassLoader classLoader)	Discovers an ObjectIdDiscovererFactory via SPI whose type() and objectIdClass() match the given arguments.
static <T> ObjectIdDiscovererFactory<T>	discoverFactory(String type, Class<T> objectIdClass, Iterable<? extends ObjectIdDiscovererFactory<?>> factories)	Discovers an ObjectIdDiscovererFactory from the given candidates whose type() and objectIdClass() match the given arguments.
Class<T>	objectIdClass()	Discovered object id type, used to distinguish TableId/ObjectId/etc.
String	type()	Storage-side type, such as jdbc, local-file, or remote-store.

Method Detail

type

String type()

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

objectIdClass

Class<T> objectIdClass()

Discovered object id type, used to distinguish TableId/ObjectId/etc.

createDiscoverer

ObjectIdDiscoverer<T> createDiscoverer()

Creates a new uninitialized ObjectIdDiscoverer.

createContext

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

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

createDiscoverer

static <T> ObjectIdDiscoverer<T> createDiscoverer(String type,
                                                  Class<T> objectIdClass,
                                                  ClassLoader classLoader)

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

discoverFactory

static <T> ObjectIdDiscovererFactory<T> discoverFactory(String type,
                                                        Class<T> objectIdClass,
                                                        ClassLoader classLoader)

Discovers an ObjectIdDiscovererFactory via SPI whose type() and objectIdClass() match the given arguments.

Throws:

IllegalArgumentException - if no factory matches the given combination.

IllegalStateException - if multiple factories match the given combination.

discoverFactory

static <T> ObjectIdDiscovererFactory<T> discoverFactory(String type,
                                                        Class<T> objectIdClass,
                                                        Iterable<? extends ObjectIdDiscovererFactory<?>> factories)

Discovers an ObjectIdDiscovererFactory from the given candidates whose type() and objectIdClass() match the given arguments.

Throws:

IllegalArgumentException - if no factory matches the given combination.

IllegalStateException - if multiple factories match the given combination.