@Giovanni阿萊格裏:
你提供的配置是注冊與火花塞多納的SQL擴展SQL。然而,注冊與PySpark塞多納的類型和功能,您需要使用一個不同的配置。
您可以添加以下配置的火花集群配置啟用自動登記塞多納與PySpark類型和函數:
火花。extraListeners org.apache.sedona.core.serde.SedonaSQLRegistrator
這將使自動登記塞多納的類型和函數創建PySpark會話時。或者,您也可以注冊塞多納類型和函數顯式地使用SedonaRegistrator.registerAll PySpark代碼(火花)方法。然而,這將要求你調用這個方法每次你創建一個新的PySpark會話。
我希望這可以幫助!
@Giovanni阿萊格裏:
你提供的配置是注冊與火花塞多納的SQL擴展SQL。然而,注冊與PySpark塞多納的類型和功能,您需要使用一個不同的配置。
您可以添加以下配置的火花集群配置啟用自動登記塞多納與PySpark類型和函數:
火花。extraListeners org.apache.sedona.core.serde.SedonaSQLRegistrator
這將使自動登記塞多納的類型和函數創建PySpark會話時。或者,您也可以注冊塞多納類型和函數顯式地使用SedonaRegistrator.registerAll PySpark代碼(火花)方法。然而,這將要求你調用這個方法每次你創建一個新的PySpark會話。
我希望這可以幫助!