spark/java上的mysql几何类型

sg3maiej  于 2021-05-27  发布在  Spark
关注(0)|答案(1)|浏览(317)

我有一个mysql表,我把它加载到spark上。该表包含具有几何图形类型的列。当我在spark上加载表时,geometry类型的列在Dataframe中变成binary类型。
我的问题是:
为什么mysql中的geometry类型在spark上变成二进制类型?
有什么办法可以解决这个问题吗?
我需要你的帮助!
谢谢您!

bnl4lu3b

bnl4lu3b1#

几何体是一种特殊的数据类型。
在使用它之前,你应该把它转换成文本或二进制。
转换信息:https://dev.mysql.com/doc/refman/5.6/en/gis-format-conversion-functions.html
也可以使用geospark:

var spatialDf = sparkSession.sql( """ |SELECT ST_GeomFromWKT(_c0) AS countyshape, _c1, _c2 |FROM rawdf """.stripMargin) spatialDf.createOrReplaceTempView("spatialdf") spatialDf.show()

完整教程如下:https://datasystemslab.github.io/geospark/tutorial/sql/

相关问题