以下是我的尝试： %sql SELECT df1.*,df1.geometry.STAsText() as geom_text FROM df_geo df1. 这显然失败了，因为它不是一个表，而是一个Dataframe。如何使用pyspark或geospark实现这一点？
%sql SELECT df1.*,df1.geometry.STAsText() as geom_text FROM df_geo df1.
qmb5sa221#
如果使用geosparksql，
SELECT *, ST_AsText(geometry) as geom_text FROM df_geo
在Pypark中：
df_geo.createOrReplaceTempView("df_geo") df2 = spark.sql("SELECT *, ST_AsText(geometry) as geom_text FROM df_geo")
1条答案
按热度按时间qmb5sa221#
如果使用geosparksql，
在Pypark中：