如何解决静态数据框上的mapGroupsWithState函数为何？
何时需要在静态数据帧上使用mapGroupsWithState函数？
根据文档（https://spark.apache.org/docs/2.2.0/api/java/org/apache/spark/sql/streaming/GroupState.html）
对于批处理数据集，只有一个调用和状态 对象将为空，因为没有先前的状态。本质上，对于 批处理数据集，[map / flatMap] GroupsWithState等效于 [map / flatMap]群组以及状态和/或超时的任何更新都有 没有效果。
那么为什么静态DataFrame中存在此方法？
解决方法
Spark 试图确保对批处理和流式处理运行相同的查询 - 大多数操作同时支持批处理和流式处理。 （营销词是“统一批处理和流式传输”。）那是“尽力而为”，并且对流式查询有现实限制，因此流式查询将不支持某些操作或工作负载。
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
