Returns a context that allows the operator to query information about the execution and also to interact with systems such as broadcast variables and

滚动聚合的逻辑（拿到一条数据，如何去更新累加器） @param value The value to add @param accumulator The accumulator to add the value to @return

TODO 累加等聚合逻辑 @param value @param accumulator GAME_ID,SERVER_ID,USER_ID max(LOG_DATE) as LOG_DATE sum(BET_MONEY) as total_bet_money sum(WIN_MONEY) as

Returns the {@link ProcessingTimeService} responsible for getting the current processing time and registering timers.

Gets the execution config defined on the execution environment of the job to which this operator belongs. @return The job's execution config.

Returns the cleanup time for a window, which is {@code window.maxTimestamp + allowedLateness}. In case this leads to a value greater than {@link Long#

Emits the contents of the given window using the {@link InternalWindowFunction}.

@param key 本次传给咱们的窗口是属于哪个key的 @param window 本次传给咱们的窗口的各种元信息（比如本窗口的起始时间，结束时间） @param input 本次传给咱们的窗口中所有数据的迭代器 @param out 结果数据输出器 @throws Exception

Retrieves the {@link MergingWindowSet} for the currently active key. The caller must ensure that the correct key is set in the state backend. <p>The

累加更新逻辑 @param acc @param value

累加更新逻辑 @param acc @param value

Drops all state for the given window and calls {@link Trigger#clear(Window, Trigger.TriggerContext)}. <p>The caller must ensure that the correct key

元素移除的核心逻辑

Return the operator name. If the runtime context has been set, then the task name with subtask index is returned. Otherwise, the simple class name is

Returns {@code true} if the given time is the cleanup time for the given window.

Indicates whether or not implementations of this class is writing to the raw keyed state streams on snapshots, using {@link #snapshotState(StateSnapsh

Returns {@code true} if the watermark is after the end timestamp plus the allowed lateness of the given window.

@param value1 是此前的聚合结果 @param value2 是本次的新数据 @return 更新后的聚合结果 @throws Exception

Registers a timer to cleanup the content of the window. @param window the window whose state to discard

组件关闭调用的方法 @throws Exception

@param first 是协同组中的第一个流的数据 @param second 是协同组中的第二个流的数据 @param out 是处理结果的输出器 @throws Exception