????????????????????????????????????????????????state????????????????????????????????????????????????Descriptor????????????null??
------------------ ???????? ------------------ ??????: "Yun Gao"<yungao...@aliyun.com.INVALID>; ????????: 2020??7??9??(??????) ????10:07 ??????: "?g???U?[????"<zhoujiazhi1...@vip.qq.com>;"user-zh"<user-zh@flink.apache.org>; ????: Re: DataStream????uv???? ?????? 1. ??????????????????????????????????????????????????????Ok???? 2. ??????????????????????????+??????????????????????????????------------------------------------------------------------------ Sender:?g???U?[????<zhoujiazhi1...@vip.qq.com> Date:2020/07/07 22:32:51 Recipient:user-zh<user-zh@flink.apache.org> Theme:DataStream????uv???? ???????? &nbsp; &nbsp; &nbsp;????????????????DataStream??api????????????UV??????????????2???????????? &nbsp; &nbsp; &nbsp;1????????Tumbling??????????????????????????????1????Time.days(1)??????????????????????????????????????uv???? &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ????????????????????????????????trigger???????????????????????????????????????????????????? &nbsp; &nbsp; &nbsp;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