使用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) 

我希望这有助于。