scala - 是否可以在自定义 AggregateWindowFunction 中使用下一行的值
问题描述
我正在使用 Spark 2.4 并实现AggregateWindowFunction. 我需要看看下一行。不幸的是，我在实现时不能使用Lead表达式，updateExpressions因为Lead从 trait 继承Unevaluable并使用它会导致运行时异常。
是否可以在自定义中检查下一行的值，AggregateWindowFunction或者我必须在调用自定义之前添加一个额外的步骤AggregateWindowFunction（此步骤可用于lead从下一行获取值，以便我可以在自定义函数中使用这些值）？
解决方案
推荐阅读
- node.js - 如何在 NodeJS 项目中使用 Google Cloud FireStore 模拟器？
- multithreading - How can I speed these API queries up?
- reactjs - Can a react component return image data so that the url mapped to that component (react-router-dom) can be used as img src=url
- angular - Angular 9 无法识别来自共享模块的 Angular 组件
- tensorflow - keras 中 LSTM 隐藏状态的随机初始化
- c - 有没有一种方法可以在每次移动时在网格中移动和显示角色而不显示新网格？
- javascript - JS/TS：从目录中读取文件我在浏览器中打开一个 HTML 文件
- model-view-controller - c# 如何在 microsoft edge 中更改 texbox (dd/MM/yyyy) 中的日期时间格式
- java - 使用 Jackson 和可选子标签反序列化 XML
- xquery - 对一系列元素执行 xdmp:node-replace() 并将其替换为一个元素