Package org.apache.flink.cdc.connectors.mysql.source.utils

Class TableDiscoveryUtils

java.lang.Object

org.apache.flink.cdc.connectors.mysql.source.utils.TableDiscoveryUtils

public class TableDiscoveryUtils
extends Object

Utilities to discovery matched tables.

Constructor Summary

Constructors

Constructor	Description
TableDiscoveryUtils()

Method Summary

Modifier and Type	Method	Description
static Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange>	discoverSchemaForCapturedTables(io.debezium.connector.mysql.MySqlPartition partition, List<io.debezium.relational.TableId> capturedTableIds, MySqlSourceConfig sourceConfig, MySqlConnection jdbc)
static Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange>	discoverSchemaForCapturedTables(io.debezium.connector.mysql.MySqlPartition partition, MySqlSourceConfig sourceConfig, MySqlConnection jdbc)
static Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange>	discoverSchemaForNewAddedTables(io.debezium.connector.mysql.MySqlPartition partition, List<io.debezium.relational.TableId> existedTables, MySqlSourceConfig sourceConfig, MySqlConnection jdbc)
static List<io.debezium.relational.TableId>	listTables(io.debezium.jdbc.JdbcConnection jdbc, java.util.function.Predicate<String> databaseFilter, java.util.function.Predicate<io.debezium.relational.TableId> tableFilter)

Methods inherited from class java.lang.Object

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

Constructor Detail

TableDiscoveryUtils

public TableDiscoveryUtils()

Method Detail

listTables

public static List<io.debezium.relational.TableId> listTables(io.debezium.jdbc.JdbcConnection jdbc,
                                                              java.util.function.Predicate<String> databaseFilter,
                                                              java.util.function.Predicate<io.debezium.relational.TableId> tableFilter)
                                                       throws SQLException

Throws:

SQLException

discoverSchemaForCapturedTables

public static Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> discoverSchemaForCapturedTables(io.debezium.connector.mysql.MySqlPartition partition,
                                                                                                                                                MySqlSourceConfig sourceConfig,
                                                                                                                                                MySqlConnection jdbc)

discoverSchemaForNewAddedTables

public static Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> discoverSchemaForNewAddedTables(io.debezium.connector.mysql.MySqlPartition partition,
                                                                                                                                                List<io.debezium.relational.TableId> existedTables,
                                                                                                                                                MySqlSourceConfig sourceConfig,
                                                                                                                                                MySqlConnection jdbc)

discoverSchemaForCapturedTables

public static Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> discoverSchemaForCapturedTables(io.debezium.connector.mysql.MySqlPartition partition,
                                                                                                                                                List<io.debezium.relational.TableId> capturedTableIds,
                                                                                                                                                MySqlSourceConfig sourceConfig,
                                                                                                                                                MySqlConnection jdbc)