关注微信公众号，定时推送前沿、专业、深度的编程技术资料。
只需一步，快速开始
加一个算子，类似在.count().toSink()
把原始日志备份到期望的存储，系统自动加上 Window 的开始时间，结束时间，如果需要额外的字段扩展，也可以在这个算子操作原始日志加期望的字段
渝公网安备 50010502003039号
