龙华网站建设主要工作,沧州网页制作公司,做网站页面怎么做,手机网站与pc网站的区别在flinkCDC源数据配置中#xff0c;只对表中的部分字段关注#xff0c;通过监控部分字段进行数据更新或者不更新#xff0c;对数据进行同步。主要通过以下两个参数#xff1a;
column.exclude.list
默认: 空字符串
一个可选的、以逗号分隔的正则表达式列表#xff0c;与…在flinkCDC源数据配置中只对表中的部分字段关注通过监控部分字段进行数据更新或者不更新对数据进行同步。主要通过以下两个参数
column.exclude.list
默认: 空字符串
一个可选的、以逗号分隔的正则表达式列表与列的完全限定名称匹配以从更改事件记录值中排除。列的完全限定名称的格式为databaseName。表名。列名。
column.include.list
默认: 空字符串
一个可选的、以逗号分隔的正则表达式列表与列的完全限定名称匹配以包含在更改事件记录值中。列的完全限定名称的格式为databaseName。表名。列名。
单表可以只写列名如果是多表、多库必须要databaseName.表名.列名这种方式的配置。 REATE TABLE IF NOT EXISTS test_source ( testid varchar ( 32 ), name int, addre varchar ( 100 ), stat int, updateTime TIMESTAMP, PRIMARY KEY ( testid ) NOT ENFORCED ) WITH ( connector mysql-cdc, hostname *******, port **, username ***, password********, database-name dbname, scan.startup.mode initial, debezium.skipped.operationsd,c, table-name tablename, debezium.column.include.listname,addre );
