27 lines
954 B
SQL
27 lines
954 B
SQL
'mutatetype' = 'insertorupdate'
|
||
insert 默认模式。仅追加写入，主键冲突时报错。 无主键冲突的流式数据（如日志）
|
||
insertorupdate UPSERT 模式：主键存在则更新整行，不存在则插入。 需要实时更新的状态表（如用户画像）
|
||
insertorignore 主键存在则忽略新数据，不存在则插入。 避免重复的维度表
|
||
insertorreplace 主键存在则删除旧行并插入新行（非更新），不存在则插入。 需要完全覆盖历史数据的场景
|
||
|
||
|
||
'ignoredelete' = 'true',
|
||
'query' = '*|where saccount <> '''',
|
||
|
||
'server-id' = '24071-24078',
|
||
'scan.startup.mode' = 'initial',
|
||
'server-time-zone' = 'Asia/Shanghai'
|
||
|
||
|
||
'binlog' = 'true',
|
||
'cdcMode' = 'true',
|
||
'upsertSource' = 'true',
|
||
'binlogMaxRetryTimes' = '10',
|
||
'binlogRetryIntervalMs' = '500',
|
||
'binlogBatchReadSize' = '100',
|
||
'startTime' = '2025-04-11 15:00:00'
|
||
|
||
|
||
|
||
'connector'='print',
|
||
'logger'='true' |