scala—flink中Spark的聚合当量

hrysbysz 于 2021-06-21 发布在 Flink

关注(0)|答案(1)|浏览(328)

对于flink的数据集，是否有spark的rdd聚合的等价物？
经过几个小时的搜索，似乎什么都没有。
flink的数据集api有一个 aggregate(agg: Aggregations, field: String): AggregateDataSet[T] 但从它的记录来看，它似乎不像Spark。
我必须实现自定义聚合吗？

scala Aggregate apache-flink

来源：https://stackoverflow.com/questions/51310770/aggregate-equivalent-of-spark-in-flink

1条答案

按热度按时间

它和spark的不完全一样，但是你看过reduce吗？

赞(0）回复(0）举报 2021-06-21

相关问题

热门标签

Java query python Node 开发语言 request Util 数据库 Table 后端算法 Logger Message Element Parser

最新问答

xxl-job 安全组扫描到执行器端口服务存在信息泄露漏洞
回答(1) 发布于 5个月前
xxl-job 不能和nacos兼容？
回答(3) 发布于 5个月前
xxl-job 任务执行完后无法结束，日志一直转圈
回答(3) 发布于 5个月前
xxl-job-admin页面上查看调度日志样式问题
回答(1) 发布于 5个月前
xxl-job 参数512字符限制能否去掉
回答(1) 发布于 5个月前