??????DataStream????uv????

Wed, 08 Jul 2020 23:19:18 -0700 

Hi,


??????????????uv??????????????????????????????????uv????????????????????????????????????????????????????[1]??????????


[1] https://lists.apache.org/thread.html/rbe00ee38e2d07310d4e3c796de86c65205d1f5deecfc1678d9ebbdea%40%3Cuser-zh.flink.apache.org%3E




------------------ ???????? ------------------
??????:&nbsp;"?g???U?[????"<[email protected]&gt;;
????????:&nbsp;2020??7??7??(??????) ????10:32
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;DataStream????uv????



????????


&amp;nbsp; &amp;nbsp; 
&amp;nbsp;????????????????DataStream??api????????????UV??????????????2????????????
&amp;nbsp; &amp;nbsp; 
&amp;nbsp;1????????Tumbling??????????????????????????????1????Time.days(1)??????????????????????????????????????uv????
&amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; 
????????????????????????????????trigger????????????????????????????????????????????????????
&amp;nbsp; &amp;nbsp; 
&amp;nbsp;2????????????????????????????????state????????????????????????????????????TTL????


DataStream<UvPer10Min&amp;gt; uvPer10MinDataStream = userBehaviorSource
.windowAll(TumblingProcessingTimeWindows.of(Time.days(1L)))
.trigger(CountTrigger.of(1L))
.evictor(CountEvictor.of(0L, true))
.process(new ProcessAllWindowFunction<UserBehavior, UvPer10Min, 
TimeWindow&amp;gt;() {
private transient MapState<String, String&amp;gt; userIdState;
private transient ValueState<Long&amp;gt; uvCountState;
&amp;nbsp; &amp;nbsp;
??????
Jiazhi

回复