输出结果： 可以输出多行，多列 @param acc @param out

输出结果： 可以输出多行，多列 @param acc @param out

窗口触发后，调用

窗口触发前，调用

如果选择的是没有内部key的redis数据结构，则此方法返回的就是大 key 如果选择的是有内部key的redis数据结构（hset），则此方法返回的是hset内部的小key，二把上面Description中传入的值作为大key @param data @return

如果选择的是没有内部key的redis数据结构，则此方法返回的就是大 key 如果选择的是有内部key的redis数据结构（hset），则此方法返回的是hset内部的小key，二把上面Description中传入的值作为大key @param data @return

Creates a partitioned state handle, using the state backend configured for this task. @throws IllegalStateException Thrown, if the key/value state wa

从累加器中，计算出最终要输出的窗口结算结果 @param accumulator The accumulator of the aggregation @return

获取累加器的值 @param accumulator the accumulator which contains the current intermediate results @return

算子任务在启动之初，会调用下面的方法，来为用户进行状态数据初始化 @param context the context for initializing the operator @throws Exception