SedonaSqlExtensions不是autoregistering類型和功能

[giohappy]

通常的方式使用Apache pySpark內塞多納首先注冊塞多納類型和函數

SedonaRegistrator.registerAll(火花)

我們需要這些autoregistered當集群開始(例如,可以執行地理空間查詢與磚SQL連接器Python)。

從我的理解自對準,可以通過添加以下集群配置,但它不工作:

spark.sql。擴展org.apache.sedona.sql.SedonaSqlExtensions

我錯過的東西嗎?

我的期望是錯的嗎?

[匿名 · Accepted solution]

@Giovanni阿萊格裏:

你提供的配置是注冊與火花塞多納的SQL擴展SQL。然而,注冊與PySpark塞多納的類型和功能,您需要使用一個不同的配置。

您可以添加以下配置的火花集群配置啟用自動登記塞多納與PySpark類型和函數:

火花。extraListeners org.apache.sedona.core.serde.SedonaSQLRegistrator

這將使自動登記塞多納的類型和函數創建PySpark會話時。或者,您也可以注冊塞多納類型和函數顯式地使用SedonaRegistrator.registerAll PySpark代碼(火花)方法。然而,這將要求你調用這個方法每次你創建一個新的PySpark會話。

我希望這可以幫助!

[Vidula_Khanna]

嗨@Giovanni阿萊格裏

謝謝你發布你的問題在我們的社區!我們很高興幫助你。

幫助我們為您提供最準確的信息,請您花一些時間來回顧反應和選擇一個最好的回答了你的問題嗎?

這也將有助於其他社區成員可能也有類似的問題在未來。謝謝你的參與,讓我們知道如果你需要任何進一步的援助!