apache-spark - 是否可以从 Spark 用户定义的聚合函数 (UDAF) 返回多行?
问题描述
是否可以从 Spark UDAF 返回多行,就像 flatMapGroups 允许您在对数据集执行 groupByKey 后返回多行一样?高性能 Spark 提到 UDAF 是比 mapGroups 更高效的替代品,所以我想知道是否有比 flatMapGroups 更高效的替代品
我知道这可以返回一个列表然后将其分解,但我想知道是否有更好的方法。
解决方案
推荐阅读
- angular - 下载远程存储的图像
- php - 文件信息扩展在 xampp php7.3.11 windows 10 中不起作用
- flutter - Flutter Web,toByteData,await 永不返回
- flutter - 如何在 Flutter 的对象数组中检查键值 id 是否退出?
- javascript - 如何返回一个对象数组,每个对象有多少个计数
- haskell - Haskell 有界数据类型,由 value-bounds 构造
- java - Java 编译没有错误,运行第一行,然后不继续或结束
- php - 来自 ajax 调用的未定义 PHP 输出
- wordpress - 无法删除“帖子首先出现”RSS
- flutter - 输入'未来
' 不是类型 'bool' shared_preferences 的子类型