火花UDAF,用于在组级别并行处理数据帧,但在每个组中依次处理行

我们在spark sql : How to achieve parallel processing of dataframe at group level but with in each group,we require sequential processing of rows

中详细讨论了我们的问题陈述

由于业务案例并不复杂,因此我们现在尝试在大数据中激发所有可能的不同选择。

请问有人可以使用Spark UDAF解决上述用例吗?

straybird9 回答:火花UDAF,用于在组级别并行处理数据帧,但在每个组中依次处理行

暂时没有好的解决方案,如果你有好的解决方案,请发邮件至:iooj@foxmail.com
本文链接:https://www.f2er.com/3143093.html

大家都在问