st_geomfromtext 使用 spark java 断言失败

Question

当我朗读下面的代码时

Dataset<Row> df = sparkSession.sql("select -7.07378166 as longitude, 33.826661 as latitude");
    df.withColumn("ST_Geomfromtext ",
            expr("ST_GeomFromText(CONCAT('POINT(',longitude,' ',latitude,')'),4326)"))
            .show(true);

我收到以下错误：

20/07/22 14:39:56 ERROR Executor: Exception in task 0.0 in stage 1.0 (TID 1)
 java.lang.AssertionError: assertion failed
at scala.Predef$.assert(Predef.scala:156)
at org.apache.spark.sql.geosparksql.expressions.ST_GeomFromText.eval(Constructors.scala:148)
at org.apache.spark.sql.catalyst.expressions.GeneratedClass$SpecificUnsafeProjection.apply(Unknown 
Source)
at org.apache.spark.sql.catalyst.expressions.GeneratedClass$SpecificUnsafeProjection.apply(Unknown 
Source)

我需要你的帮助

谢谢

Answer 1

从源代码来看，函数 ST_GeomFromText 只需要 1 个表达式，但您有 2 个 - concat(..) 和 4326

检查例子here

st_geomfromtext 使用 spark java 断言失败

st_geomfromtext assertion failed using spark java

java

apache-spark

geospark