#

利用flink统计消息回复情况

  • 利用flink统计消息回复情况

    其中用到了滑动窗口函数大小30秒,间隔15秒,且大于窗口10秒的数据,被丢弃。(实际业务这三个值 应为是 10 分钟,1分钟,5分钟)。代码先记录一下 public static void main(

    作者:大海之中
    2020-05-26 11:17:50