看了官方文档说是合并Accumulator，但是我这个方法即便return null 也不会有任何影响呀？
什么情况下会调用这个方法呢？
Flink AggregateFunction中的merge方法是做什么用的？
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
分享- 邀请回答
-
2条回答 默认 最新
- 2022-06-05 15:31回答 1 已采纳 我的打印出来了，，，我代码是这样的 import org.apache.flink.api.common.RuntimeExecutionMode; import org.apache.flink.
- 2022-04-04 22:57回答 2 已采纳 本地执行需要去掉，依赖范围provided，可以查看我的微博，flink专栏
- 2022-01-02 12:03回答 2 已采纳 scala的换成 createRemoteEnvironment，getExecutionEnvironment只是其中一种方法
- 2023-11-07 22:00lixia0417mul2的博客 AggregateFunction.merge的使用
- 2021-07-13 21:54回答 1 已采纳 看你用的哪个版本，如果1.11.2以上，flink sql还可以
- 2022-04-24 14:53回答 2 已采纳 这样好像不行，你可以换一种思路。 写linux脚本，定时提交作业 Linux Crontab 定时任务 麻烦采纳一下，你的采纳，是对我最好的鼓励，谢谢！
- 2023-03-07 15:49回答 4 已采纳 Flink 在启动任务的时候，创建输入分片时发生了错误，导致无法启动任务。你需要检查一下程序中读取文件的代码是否正确，文件路径是否正确，文件是否存在，并且当前用户是否有访问该文件的权限。如果需要，可以
- 2022-04-15 14:20二十六画生的博客的博客 在我们使用Flink DataStream API编写业务代码时，aggregate()算子和AggregateFunction无疑是非常常用的。编写一个AggregateFunction需要实现4个方法： public interface AggregateFunction<IN, ACC, OUT> ...
- 回答 1 已采纳 应该是你main方法中引入的第三方包和项目中的包冲突了
- 2021-11-03 15:10回答 1 已采纳 文档：https://ci.apache.org/projects/flink/flink-docs-release-1.13/zh/docs/dev/table/sql/queries/overvi
- 2022-02-09 15:08回答 2 已采纳 在这里：https://github.com/apache/flink/tree/69d9fade5b0e3629c84548c06f0624e9e66fdefe/flink-connectors/f
- 2020-09-13 21:57LittleMagics的博客 在我们使用Flink DataStream API编写业务代码时，aggregate()算子和AggregateFunction无疑是非常常用的。编写一个AggregateFunction需要实现4个方法： public interface AggregateFunction<IN, ACC, OUT> ...
- 2022-01-11 10:12回答 2 已采纳 这是空指针异常，发生在读取数据那里，仔细检查一下数据是否有问题，估计是数据格式出现了问题或者路径输出了问题导致没有读取到自己想要的数据,无法被获取到，所以报了空异常
- 2023-07-17 11:59青云游子的博客 实际上，这个方法是专门为会话窗口（session window）服务的。下面来解析一下会话窗口。MergingWindowAssigner是一个抽象类，代码很简单，定义了用于合并窗口的mergeWindows()方法以及合并窗口时的回调MergeCallback...
- 2023-06-06 11:21飞天小老头的博客 AggregateFunction的使用
- 没有解决我的问题, 去提问
悬赏问题
- ¥30 求一段fortran代码用IVF编译运行的结果
- ¥15 深度学习根据CNN网络模型，搭建BP模型并训练MNIST数据集
- ¥15 lammps拉伸应力应变曲线分析
- ¥15 C++ 头文件/宏冲突问题解决
- ¥15 用comsol模拟大气湍流通过底部加热（温度不同）的腔体
- ¥50 安卓adb backup备份子用户应用数据失败
- ¥20 有人能用聚类分析帮我分析一下文本内容嘛
- ¥15 请问Lammps做复合材料拉伸模拟，应力应变曲线问题
- ¥30 python代码，帮调试，帮帮忙吧
- ¥15 #MATLAB仿真#车辆换道路径规划