????????????Flink trigger????????????????????

??Evictor?? BestJun -- -- ??: Qi Kang

如何让Flink trigger只输出有变化的数据？

Hi, 我们有一个按自然天聚合统计各站点销量和GMV数据的Flink任务，代码框架如下： ``` sourceStream .map(message -> JSON.parseObject(message, OrderDetail.class)) .keyby("siteId") .window(TumblingProcessingTimeWindows.of(Time.days(1), Time.hours(-8))) .trigger(ContinuousProcessingTimeTrigger.of(Time.seconds(1)))