如何在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")