apache flink-sum和数据流中的组

bbmckpt7  于 2021-06-25  发布在  Flink
关注(0)|答案(0)|浏览(294)

假设我有这样的记录:

("a-b", "data1", 1)
("a-c", "data2", 1)
("a-b", "data3", 1)

如何在apache flink中进行分组和求和,以便在输入为数据流时得到以下结果?

("a-b", ["data1", "data3"], 2)
("a-c", ["data2"], 1)

我只能通过使用{time,count}窗口,然后分组并应用转换,或者通过将元素保留在迭代流中(但这需要大量内存)来考虑解决方案。
你好,凯文

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题