st_geomfromwkt

WKT 記述を解析し、対応するジオメトリ値を返します。

対応する Databricks SQL 関数については、 st_geomfromwkt関数を参照してください。

構文

Python

from pyspark.databricks.sql import functions as dbf

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

パラメーター

パラメーター	Type	説明
col1	pyspark.sql.Column または str	ジオメトリ値を表す WKT 形式の文字列。
col2	pyspark.sql.Column またはint （オプション）	ジオメトリのオプションの SRID。デフォルトは0です。

パラメーター	Type	説明
col1	pyspark.sql.Column または str	ジオメトリ値を表す WKT 形式の文字列。
col2	pyspark.sql.Column またはint （オプション）	ジオメトリのオプションの SRID。デフォルトは0です。

例

Python

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()

Output

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

Python

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()

Output

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