использование искра SQL UDF в dataframe API

Question

Как я могу использовать UDF, который отлично работает в искре, как

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

взят из из http://www.geomesa.org/documentation/user/spark/sparksql.html через spark`s дополнительного типизированного API dataframe лестницы?

Answer 1

Если вы создали функцию, вы можете зарегистрировать созданную UDF с помощью:

sparksession.sqlContext.udf.register(yourFunction) 

Я надеюсь, что это помогает.