
当有携带15毫秒时间戳数据进来时,窗口关闭,进行计算,此时窗口中的数据包含0=<数据<10毫秒(左开右闭)的数据,水位线为9毫秒(窗口时间-1毫秒)窗口已关闭,数据依然到来时,可采用测输出流的方式来确保精确一次,为保证精确一次,最终处理方式是将窗口保存至数据库的数据查询出来,然后再与侧边输出统计的数据进行二次计算,然后更新至数据库。
欢迎分享,转载请注明来源:内存溢出

当有携带15毫秒时间戳数据进来时,窗口关闭,进行计算,此时窗口中的数据包含0=<数据<10毫秒(左开右闭)的数据,水位线为9毫秒(窗口时间-1毫秒)窗口已关闭,数据依然到来时,可采用测输出流的方式来确保精确一次,为保证精确一次,最终处理方式是将窗口保存至数据库的数据查询出来,然后再与侧边输出统计的数据进行二次计算,然后更新至数据库。
欢迎分享,转载请注明来源:内存溢出
微信扫一扫
支付宝扫一扫
评论列表(0条)