阅读 spark 指南后，我不清楚在使用 spark ES 时是否可以使用自定义原语执行 DFS。我知道在 spark ES 上可以兼容哪种原语存在限制，但不知道是否可以添加我自己的自定义兼容原语。对此的任何澄清都会非常有帮助，谢谢。
我尝试阅读文档/指南，我希望看到更多关于在 spark 上使用自定义原语的讨论。我没有看到他们提到不受支持，所以我决定在这里问一下。