問題描述
ST_WITHIN 使用 Spark/Java (ST_WITHIN using Spark / Java)
我有以下數據框：
+‑‑‑‑‑‑‑‑‑‑‑‑‑+‑‑‑‑‑‑‑‑‑‑‑‑‑‑‑‑‑+‑‑‑‑‑‑‑‑‑‑‑‑‑‑‑‑‑‑+
|longitude |latitude |geom |
+‑‑‑‑‑‑‑‑‑‑‑‑‑+‑‑‑‑‑‑‑‑‑‑‑‑‑‑‑‑‑+‑‑‑‑‑‑‑‑‑‑‑‑‑‑‑‑‑‑+
|‑7.07378166 |33.826661 [00 00 00 00 01 0..|
|‑7.5952683 |33.544191 [00 00 00 00 01 0..|
+‑‑‑‑‑‑‑‑‑‑‑‑‑+‑‑‑‑‑‑‑‑‑‑‑‑‑‑‑‑‑+‑‑‑‑‑‑‑‑‑‑‑‑‑‑‑‑‑‑+
我正在使用以下代碼：
Dataset<Row> result_f = sparkSession.sql("select * from data_f where ST_WITHIN(ST_GeomFromText(CONCAT('POINT(',longitude_f,' ',latitude_f,')',4326)),geom)");
result_f.show();
但我收到以下錯誤：
java.lang.ClassCastException: [B cannot be cast to org.apache.spark.sql.catalyst.util.ArrayData
at org.apache.spark.sql.geosparksql.expressions.ST_Within.eval(Predicates.scala:105)
編輯
longitude : Double type
latitude : Double type
geom : Binary type
有什麼想法嗎？我需要你的幫助
謝謝
參考解法
方法 1:
I don't think ST_GeomFromText is availble as constructing a geometry from text however there are:
- ST_GeomFromWKT
- ST_GeomFromWKB
- ST_GeomFromGeoJSON
- ST_Point
- ST_PointFromText
- ST_PolygonFromText
- ST_LineStringFromText
- ST_PolygonFromEnvelope
- ST_Circle
</ul>
I suggest to use either ST_Point or ST_PointFromText and after that the predicate ST_WITHIN
Something like this:
Dataset<Row> result_f = sparkSession.sql("select * from data_f where ST_WITHIN(ST_Point(CAST(data_f.latitude AS Decimal(24,20)), CAST(data_f.longitude AS Decimal(24,20))),geom)");
result_f.show();