例如：
有一个视频播放日志，格式为：用户id、视频id、播放持续时间、视频持续时间、国家/地区、请求日期
我想计算：
答。最后一分钟的游戏事件数
b。今天的比赛项目数
c。最近一小时最受欢迎的十大视频（播放次数）
d。最近一小时最活跃的前10名用户（播放时间）
在上述4个任务中，它们使用相同的源，但有三个不同的时间窗口。有没有什么有效的解决方案来完成这些工作，而不启动3或4个工作岗位来复制消费。
例如：
有一个视频播放日志，格式为：用户id、视频id、播放持续时间、视频持续时间、国家/地区、请求日期
我想计算：
答。最后一分钟的游戏事件数
b。今天的比赛项目数
c。最近一小时最受欢迎的十大视频（播放次数）
d。最近一小时最活跃的前10名用户（播放时间）
在上述4个任务中，它们使用相同的源，但有三个不同的时间窗口。有没有什么有效的解决方案来完成这些工作，而不启动3或4个工作岗位来复制消费。
1条答案
按热度按时间cu6pst1q1#
您可以有一个将流拆分为4路的作业，然后将这些窗口操作符中的一个附加到每个复制的流。您可以使用split/select或side输出进行拆分。