使用SQL火花UDF

Question

我如何使用UDF這火花像

sparkSession.sql("select * from chicago where st_contains(st_makeBBOX(0.0, 0.0, 90.0, 90.0), geom)").show 

通過spark`s更多類型安全斯卡拉數據幀從API http://www.geomesa.org/documentation/user/spark/sparksql.html 取自偉大工程？

Answer 1

如果您已經創建了一個功能，您可以通過註冊創建UDF：

sparksession.sqlContext.udf.register(yourFunction) 

我希望這有助於。