开发者社区> 问答> 正文

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

例如:

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

我想计算:

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

B.今天的比赛数量

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

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

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

展开
收起
flink小助手 2018-12-10 13:41:24 2753 0
1 条回答
写回答
取消 提交回答
  • flink小助手会定期更新直播回顾等资料和文章干货,还整合了大家在钉群提出的有关flink的问题及回答。

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

    2019-07-17 23:19:14
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载