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

[?g???U?[????]

??????????




------------------ ???????? ------------------
??????:&nbsp;"1193216154"<1193216...@qq.com&gt;;
????????:&nbsp;2020??7??9??(??????) ????10:25
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

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



??????????ContinuousEventTimeTrigger??????????????????????????????
??????countTrigger??????????????????????????????processWindowFunction??????????????????????
????????aggregateWindowFuntion




------------------&amp;nbsp;????????&amp;nbsp;------------------
??????:&amp;nbsp;"Yun Gao"<yungao...@aliyun.com.INVALID&amp;gt;;
????????:&amp;nbsp;2020??7??9??(??????) ????10:18
??????:&amp;nbsp;"?g???U?[????"<zhoujiazhi1...@vip.qq.com&amp;gt;;"user-zh"<user-zh@flink.apache.org&amp;gt;;

????:&amp;nbsp;Re: ?????? DataStream????uv????



????????????????????????????????????????????????????????key??time??????????????????????????????????????????????????????????



&amp;nbsp;------------------Original Mail ------------------
Sender:?g???U?[???? <zhoujiazhi1...@vip.qq.com&amp;gt;
Send Date:Thu Jul 9 10:16:06 2020
Recipients:user-zh <user-zh@flink.apache.org&amp;gt;
Subject:?????? DataStream????uv????
????????????????????????????????????????????????state????????????????????????????????????????????????Descriptor????????????null??


------------------&amp;amp;nbsp;????????&amp;amp;nbsp;------------------
??????:&amp;amp;nbsp;"Yun Gao"<yungao...@aliyun.com.INVALID&amp;amp;gt;;
????????:&amp;amp;nbsp;2020??7??9??(??????) ????10:07
??????:&amp;amp;nbsp;"?g???U?[????"<zhoujiazhi1...@vip.qq.com&amp;amp;gt;;"user-zh"<user-zh@flink.apache.org&amp;amp;gt;;

????:&amp;amp;nbsp;Re: DataStream????uv????




??????
&amp;amp;nbsp;&amp;amp;nbsp; 1. 
??????????????????????????????????????????????????????Ok????
&amp;amp;nbsp;&amp;amp;nbsp; 2. 
??????????????????????????+??????????????????????????????------------------------------------------------------------------
Sender:?g???U?[????<zhoujiazhi1...@vip.qq.com&amp;amp;gt;
Date:2020/07/07 22:32:51
Recipient:user-zh<user-zh@flink.apache.org&amp;amp;gt;
Theme:DataStream????uv????

????????


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


DataStream<UvPer10Min&amp;amp;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;amp;amp;gt;() {
private transient MapState<String, String&amp;amp;amp;gt; userIdState;
private transient ValueState<Long&amp;amp;amp;gt; uvCountState;
&amp;amp;amp;nbsp; &amp;amp;amp;nbsp;
??????
Jiazhi