dataframe - 如何在 pyspark 数据框中将几何列从二进制格式转换为字符串格式？

Question

这是我的尝试：

%sql SELECT df1.*,df1.geometry.STAsText() as geom_text FROM df_geo df1.

这显然失败了，因为它不是一个表，而是一个数据框。如何使用 pyspark 或 geospark 做到这一点？

Answer 1

如果您使用 GeoSparkSQL，

SELECT *, ST_AsText(geometry) as geom_text FROM df_geo

在 pyspark 中：

df_geo.createOrReplaceTempView("df_geo")
df2 = spark.sql("SELECT *, ST_AsText(geometry) as geom_text FROM df_geo")