假设我有这样的记录:
("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}窗口,然后分组并应用转换,或者通过将元素保留在迭代流中(但这需要大量内存)来考虑解决方案。你好,凯文
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!