st_geomfromwkb

入力された WKB 記述を解析し、対応するジオメトリ値を返します。

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

構文

Python

from pyspark.databricks.sql import functions as dbf

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

パラメーター

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

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

例

Python

from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([(bytes.fromhex('010200000002000000000000000000144000000000000018400000000000001c4000000000000020c0'),)], ['wkb'])
df.select(dbf.st_asewkt(dbf.st_geomfromwkb('wkb')).alias('result')).collect()

Output

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

Python

from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([(bytes.fromhex('010200000002000000000000000000144000000000000018400000000000001c4000000000000020c0'), 4326,)], ['wkb', 'srid'])
df.select(dbf.st_asewkt(dbf.st_geomfromwkb('wkb', 'srid')).alias('result')).collect()

Output

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