Deletes the cleanup timer set for the contents of the provided window. @param window the window whose state to discard

Returns a {@link InternalTimerService} that can be used to query current processing time and event time and to set timers. An operator can have severa

用于计算移除的时间截止点

Decide if a record is currently late, based on current watermark and allowed lateness. @param element The element to check @return The element for wh

要让flink来帮助管理的状态数据 ，那就不要自己定义一个变量 而是要从flink的api中去获取一个状态管理器，用这个状态管理器来进行数据的增删改查等操作 这种状态： 叫做 托管状态 ！ (flink state)

正常的MapFunction的处理逻辑方法 @param value The input value. @return @throws Exception

source组件初始化 @param parameters @throws Exception

Write skipped late arriving element to SideOutput. @param element skipped late arriving element to side output

Creates a new watermark generator with the given out-of-orderness bound. @param maxOutOfOrderness The bound for the out-of-orderness of the event tim

@param userPart @param collector @param slowFactor 速度因子，事件间隔时长=RandomUtils.nextInt(50+10 slowFactor,100 slowFactor)

Creates a new {@code WindowOperator} based on the given policies and user functions.

进来输入数据后，如何更新累加器 @param accumulator @param score

job取消调用的方法

初始化累加器 @return

创建累加器 @return