DataStream????uv????

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

????????


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


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