????????????????????????????????????????????????????????????????flink??????????clickHouse??????????????????????????????????flink1.12.1????????kafka????????????upsert????????????????clickhouse??????????????????????????????????????
clickhouse??????????????
CREATE TABLE test_local.tzling_tb3(
uuid String,
product String,
platform String,
batchId String,
id String,
account String,
customerId String,
reportName String,
dt String,
campaign String,
adGroup String,
generalField String,
currency String,
impressions String,
cost String,
clicks String,
conversions String,
createDateTime String,
createTime BIGINT,
key String,
pdate String
)engine = MergeTree PARTITION BY pdate order by createTime;
??uuid???????????????????????????? update????????????????????append??
processData.addSink(new MSKUpsertClickHouseSink());
????????MSKUpsertClickHouseSink.java????????clickhouse??sink????????????????
??????????????????????????????uuid??????????????????????????????????append??????????????????????uuid??????????????append??????????????????????????????,??????????????1??????clickhouse????????uuid??????????????????
????????????????????????????????????????????????????????????????????
