java - 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

在此处查看示例