一、目的
清洗ClickHouse的ODS层原始数据,增量导入到DWD层表中
二、实施步骤
2.1 newtime
select(
select
create_time
from hurys_jw.dwd_statistics
order by create_time desc limit 1) as create_time
2.2 替换NULL值
2.3 clickhouse输入
2.4 字段选择
2.5 clickhouse输出
2.6 kettle运行
搞定!!!