Flink大数据实时计算系列-第一个程序JAVA版本-分组统计 ProcessFunction写法

ProcessFunction的onTimer方法

onTimer方法到点就回调，相当于执行一个时间窗口。

代码应用

            @Override
            public void onTimer(long timestamp, OnTimerContext ctx, Collector