跳到主要内容
版本: 1.1

MySQLCDC 整库到 HiveCatalog

整库同步到 HiveCatalog

EXECUTE CDCSOURCE demo WITH (
'connector' = 'mysql-cdc',
'hostname' = '127.0.0.1',
'port' = '3306',
'username' = 'root',
'password' = '123456',
'checkpoint' = '10000',
'scan.startup.mode' = 'initial',
'parallelism' = '1',
'table-name' = 'test\..*',
'sink.connector' = 'sql-catalog',
'sink.catalog.name' = 'hive',
'sink.catalog.type' = 'hive',
'sink.sink.db' = 'hdb',
'sink.catalog.hive-conf-dir' = '/usr/local/dlink/hive-conf'
);