org.apache.paimon.flink.action.cdc.mysql

Class MySqlActionUtils

java.lang.Object

org.apache.paimon.flink.action.cdc.mysql.MySqlActionUtils

public class MySqlActionUtils
extends Object

Utils for MySQL Action.

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.flink.configuration.ConfigOption<Boolean>	SCAN_NEWLY_ADDED_TABLE_ENABLED

Constructor Summary

Constructors

Constructor and Description
MySqlActionUtils()

Method Summary

Modifier and Type	Method and Description
static org.apache.flink.cdc.connectors.mysql.source.MySqlSource<CdcSourceRecord>	buildMySqlSource(org.apache.flink.configuration.Configuration mySqlConfig, String tableList, TypeMapping typeMapping)
static CdcTimestampExtractor	createCdcTimestampExtractor()
static JdbcSchemasInfo	getMySqlTableInfos(org.apache.flink.configuration.Configuration mySqlConfig, java.util.function.Predicate<String> monitorTablePredication, List<Identifier> excludedTables, TypeMapping typeMapping)
static void	registerJdbcDriver()

Methods inherited from class java.lang.Object

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

Field Detail

SCAN_NEWLY_ADDED_TABLE_ENABLED

public static final org.apache.flink.configuration.ConfigOption<Boolean> SCAN_NEWLY_ADDED_TABLE_ENABLED

Constructor Detail

MySqlActionUtils

public MySqlActionUtils()

Method Detail

getMySqlTableInfos

public static JdbcSchemasInfo getMySqlTableInfos(org.apache.flink.configuration.Configuration mySqlConfig,
                                                 java.util.function.Predicate<String> monitorTablePredication,
                                                 List<Identifier> excludedTables,
                                                 TypeMapping typeMapping)
                                          throws Exception

Throws:

Exception

buildMySqlSource

public static org.apache.flink.cdc.connectors.mysql.source.MySqlSource<CdcSourceRecord> buildMySqlSource(org.apache.flink.configuration.Configuration mySqlConfig,
                                                                                                         String tableList,
                                                                                                         TypeMapping typeMapping)

registerJdbcDriver

public static void registerJdbcDriver()

createCdcTimestampExtractor

public static CdcTimestampExtractor createCdcTimestampExtractor()