Flink实时统计GMV,如果订单金额下午变了该怎么处理
根据 update /delete 要写这个减去的逻辑。
按日去重是不行了,因为是增量处理, 上午的数据已经被处理了不能再获取了。
去重语法:
SELECT [column_list]
FROM (
SELECT [column_list],
ROW_NUMBER() OVER ([PARTITION BY col1[, col2...]]
ORDER BY time_attr [asc|desc]) AS rownum
FROM table_name)
WHERE rownum = 1
只要source端产生了changelog数据,后面的算子是可以自动处理update消息的,简单理解,你可以认为: