如何在 spark scala 数据框(非文本)api 中访问 geomesas UDF?即如何转换
如何使 sql UDF 在 scala 数据框 DSL 中可用的文本 spark-sql API 中可用?即如何启用而不是这个表达式
spark.sql("select st_asText(st_bufferPoint(geom,10)) from chicago where case_number = 1")
类似于
df.select(st_asText(st_bufferPoint('geom, 10))).filter('case_number === 1)
如何注册 geomesas UDF,使其不仅适用于 sql 文本模式。SQLTypes.init(spark.sqlContext)
来自https://github.com/locationtech/geomesa/blob/f13d251f4d8ad68f4339b871a3283e43c39ad428/geomesa-spark/geomesa-spark-sql/src/main/scala/org/apache/spark/sql/SQLTypes.scala#L59-L66似乎只有注册文本表达式。
我已经在导入
import org.apache.spark.sql.functions._
所以这些功能
应该可用。