@param element 广播流中的一条数据 @param ctx 上下文 @param out 输出器 @throws Exception

@param eventLog 输入数据 @param ctx 上下文，它能提供“测输出“功能 @param out 主流输出收集器 @throws Exception

本方法，是用来处理 主流中的数据（每来一条，调用一次） @param element 左流（主流）中的一条数据 @param ctx 上下文 @param out 输出器 @throws Exception

Override the base implementation to completely ignore watermarks propagated from upstream, except for the "end of time" watermark.

source组件生成数据的过程（核心工作逻辑） @param ctx @throws Exception

@deprecated The {@link ProcessingTimeService} instance should be passed by the operator constructor and this method will be removed along with {@l

系统对状态数据做快照（持久化）时会调用的方法，用户利用这个方法，在持久化前，对状态数据做一些操控 @param context the context for drawing a snapshot of the operator @throws Exception