开发者社区> 问答> 正文

如何有效地计算来自一个源的多个flink流

flink小助手 2018-12-10 13:41:24 519

例如:

有一个视频播放日志,格式为:user_id,video_id,play_duration,video_duration,country,request_date

我想计算:

A.最后一分钟的比赛次数

B.今天的比赛数量

C.在过去一小时内排名前10的最受欢迎的视频(播放时间)

D.在过去一小时内排名前10的最活跃用户(游戏时间)

在上述4个任务中,它们使用相同的源,但具有三个不同的时间窗口。是否有任何有效的解决方案来完成这些工作,而无需启动3或4个工作来复制消耗。

流计算
分享到
取消 提交回答
全部回答(1)
  • flink小助手
    2019-07-17 23:19:14

    您可以使用单个作业以4种方式拆分流,然后将其中一个窗口运算符附加到每个复制的流中。您可以使用分割/选择或侧输出进行分割。

    0 0
+ 订阅

大数据计算实践乐园,近距离学习前沿技术

推荐文章
相似问题