????????????????????????10??????????????1??????.window(TumblingEventTimeWindows.of(Time.minutes(10))).trigger(ContinuousEventTimeTrigger.of(Time.minutes(1)))????????????????10????????????????????????????????????????????????????????????????????????????
------------------ ???????? ------------------ ??????: "user-zh" <wangwangdaxian...@gmail.com>; ????????: 2020??8??26??(??????) ????1:31 ??????: "user-zh@flink.apache.org"<user-zh@flink.apache.org>; ????: Re: ProcessWindowFunction??????clear??????????????????-v1.10.1 ????????????????aggregate(AggregateFunction<T, ACC, V> aggFunction, ProcessWindowFunction<V, R, K, W> windowFunction)?????? ????????????????????????????????????????processWindowFunction????????????????????????????context??????????????state?????????? x <35907...@qq.com> ??2020??8??25?????? ????6:25?????? > > ????????????????????????????ProcessWindowFunction??clear????????????????????????????????????????????????????????????????????????????????env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)?????????? > .window(TumblingEventTimeWindows.of(Time.days(1))) > .trigger(ContinuousEventTimeTrigger.of(Time.minutes(1))) > .evictor(TimeEvictor.of(Time.seconds(0), true)) > .process(new ProcessWindowFunction[IN,OUT,KEY,TimeWindow]{ > private var state: MapState[String,Boolean] = _ > override def open > override def process > override def clear(ctx: Context): Unit = { > state.clear() > } > }