我有一个mysql表,我把它加载到spark上。该表包含具有几何图形类型的列。当我在spark上加载表时,geometry类型的列在Dataframe中变成binary类型。我的问题是:为什么mysql中的geometry类型在spark上变成二进制类型?有什么办法可以解决这个问题吗?我需要你的帮助!谢谢您!
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/
1条答案
按热度按时间bnl4lu3b1#
几何体是一种特殊的数据类型。
在使用它之前,你应该把它转换成文本或二进制。
转换信息:https://dev.mysql.com/doc/refman/5.6/en/gis-format-conversion-functions.html
也可以使用geospark:
完整教程如下:https://datasystemslab.github.io/geospark/tutorial/sql/