Package org.apache.flink.cdc.connectors.oceanbase.table

Class OceanBaseMySqlTableSourceFactory

java.lang.Object

org.apache.flink.cdc.connectors.mysql.table.MySqlTableSourceFactory

org.apache.flink.cdc.connectors.oceanbase.table.OceanBaseMySqlTableSourceFactory

All Implemented Interfaces:

org.apache.flink.table.factories.DynamicTableFactory, org.apache.flink.table.factories.DynamicTableSourceFactory, org.apache.flink.table.factories.Factory

public class OceanBaseMySqlTableSourceFactory
extends MySqlTableSourceFactory

Factory class for creating table sources that capture data changes from OceanBase databases.

This factory extends MySqlTableSourceFactory to reuse MySQL CDC connector.

Key characteristics:

• Identified by factory identifier "oceanbase-cdc"
• Compatible with OceanBase Binlog Service

See Also:

Base MySQL implementation

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.factories.DynamicTableFactory

org.apache.flink.table.factories.DynamicTableFactory.Context

Constructor Summary

Constructors

Constructor	Description
OceanBaseMySqlTableSourceFactory()

Method Summary

Modifier and Type	Method	Description
String	factoryIdentifier()

Methods inherited from class org.apache.flink.cdc.connectors.mysql.table.MySqlTableSourceFactory

createDynamicTableSource, optionalOptions, requiredOptions

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.table.factories.DynamicTableFactory

forwardOptions

Constructor Detail

OceanBaseMySqlTableSourceFactory

public OceanBaseMySqlTableSourceFactory()

Method Detail

factoryIdentifier

public String factoryIdentifier()

Specified by:

factoryIdentifier in interface org.apache.flink.table.factories.Factory

Overrides:

factoryIdentifier in class MySqlTableSourceFactory