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

2019-11-01 文章 Jun Zhang 
??Evictor??

BestJun


--  --
??: Qi Kang

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

2019-11-01 文章 Qi Kang 
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)))
  .aggregate(new VolumeGmvAggregateFunc());
```

为了能够让dashboard实时刷新数据，每秒会触发一次计算。但是站点有将近1000个，每秒都输出全量结果不太现实，请问有什么简便的方法能够仅输出一秒内发生过变化的站点数据呢？Thx.