st_geomfromwkt

這很重要

這項功能目前處於 公開預覽版。

解析 WKT 描述並回傳對應 的幾何 值。

關於對應的 Databricks SQL 函式，請參見 st_geomfromwkt 函數。

語法

from pyspark.databricks.sql import functions as dbf

dbf.st_geomfromwkt(col1=<col1>, col2=<col2>)

參數

參數	類型	Description
col1	pyspark.sql.Column 或 str	一個 WKT 格式的字串，代表一個幾何值。
col2	pyspark.sql.Column 或 int，選用	幾何的可選參數 SRID。 預設值為 0。

範例

from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('LINESTRING(5 6,7 -8)',)], ['wkt'])
df.select(dbf.st_astext(dbf.st_geomfromwkt('wkt')).alias('result')).collect()

[Row(result='LINESTRING(5 6,7 -8)')]

from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('LINESTRING(5 6,7 -8)', 3857,)], ['wkt', 'srid'])
df.select(dbf.st_astext(dbf.st_geomfromwkt('wkt', 'srid')).alias('result')).collect()

[Row(result='LINESTRING(5 6,7 -8)')]