比如这样？ dataStream.timeWindow(...) // 5m dataStream.timeWindow(...) // 15m dataStream.timeWindow(...) // 30m ...
刘晨 <aegean0...@163.com> 于2019年7月19日周五 下午2:07写道： > 您好: > 请问, 在进行流计算时, source相同, 处理逻辑相同, 但要计算不同的滑动时间窗口, > 比如 每分钟统计最近 5m,15m,30m 以及 每15分钟计算, 1h, 3h , 12h的数据 > 除去每种窗口写一个程序外, 有其他更加便捷的解决方式吗 ? > > > 谢谢
