如何将 pyspark 数据框中的几何列从二进制格式转换为字符串格式?
How do I convert a geometry column from binary format to string format in a pyspark dataframe?
这是我的尝试:
%sql SELECT df1.*,df1.geometry.STAsText() as geom_text FROM df_geo df1.
这显然失败了,因为它不是 table,而是数据帧。如何使用 pyspark 或 geospark 做到这一点?
如果您使用 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")
这是我的尝试:
%sql SELECT df1.*,df1.geometry.STAsText() as geom_text FROM df_geo df1.
这显然失败了,因为它不是 table,而是数据帧。如何使用 pyspark 或 geospark 做到这一点?
如果您使用 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")