开发者社区> 问答> 正文

[Filnk] 关于合并的keyed stream的sink问题

有两条keyed stream, 一条是根据userid聚合求点击数click,另一条是根据同样的userid聚合求曝光数show,都是key("userid").sum(1),假设窗口期设置一样。现在想让最后sink时按照三个字段userid,click,show在同一个窗口期同时落DB,如在某个窗口期的sink是往DB里写一条记录:userid=8888,click=5,show=20,这种情况该如何合并stream呢?

展开
收起
太初123 2018-11-23 22:14:06 1932 0
0 条回答
写回答
取消 提交回答
问答地址:
问答排行榜
最热
最新

相关电子书

更多
BUILDING REALTIME DATA PIPELINES WITH KAFKA CONNECT AND SPARK STREAMING 立即下载
A stream processing pipeline S 立即下载
LEARNINGS USING SPARK STREAMING & DATAFRAMES FOR WALMART SEARCH 立即下载