MySQL几何类型在Spark / Java上的使用

huangapple go评论79阅读模式
英文:

MySQL geometry type on Spark / Java

问题

我有一个 MySQL 表,我在 Spark 上加载它。该表包含一个几何类型的列。
当我在 Spark 上加载该表时,几何类型的列在数据框中变为二进制类型。

我的问题是:

  • 为什么 MySQL 中的几何类型在 Spark 上变为二进制类型?
  • 是否有其他解决方法来修复这个问题?

我需要你的帮助!
谢谢!

英文:

I have a MySQL table and I load it on spark. The table contains a column with geometry type.
When I load the table on spark, the column with geometry type becomes with binary type in data frame.

My questions are:

  • Why the geometry type in MySQL becomes binary type on spark ?
  • Is there any alternative to fix that ?

I need your help!

Thank you!

答案1

得分: 1

以下是您要求的翻译部分:

几何类型是一种特殊的数据类型。

在使用之前,您应该将其转换为文本或二进制。

转换信息: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/

英文:

Geometry is a special data type.

Before use it, you should convert it to text or bynary.

Conversion info: https://dev.mysql.com/doc/refman/5.6/en/gis-format-conversion-functions.html

Or you can use GeoSpark:

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

Full tutorial below:
https://datasystemslab.github.io/GeoSpark/tutorial/sql/

huangapple
  • 本文由 发表于 2020年7月25日 04:07:44
  • 转载请务必保留本文链接:https://go.coder-hub.com/63080758.html
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定