ProcessWindowFunction??????clear??????????????????-v1.10.1

[x]

????????????????????????????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()
}
}