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

Fri, 01 Nov 2019 06:02:27 -0700 

??????????????Evictor??????????????????????????

Best  Jun


------------------ ???????? ------------------
??????: Qi Kang <[email protected]&gt;
????????: 2019??11??1?? 16:37
??????: user-zh <[email protected]&gt;
????: ????????????Flink trigger????????????????????



Hi,

??????????????????????????????????????GMV??????Flink????????????????????

```
sourceStream
&nbsp; .map(message -&gt; JSON.parseObject(message, OrderDetail.class))
&nbsp; .keyby("siteId")
&nbsp; .window(TumblingProcessingTimeWindows.of(Time.days(1), Time.hours(-8)))
&nbsp; .trigger(ContinuousProcessingTimeTrigger.of(Time.seconds(1)))
&nbsp; .aggregate(new VolumeGmvAggregateFunc());
```

??????????dashboard????????????????????????????????????????????????1000????????????????????????????????????????????????????????????????????????????????????????????Thx.

回复