メインコンテンツまでスキップ

地理へ

備考

プレビュー

この機能は パブリック プレビュー段階です。

入力された BINARY または文字列値を解析し、対応するGeography値を返します。無効な入力の場合、エラーがスローされます。

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

構文

Python
from pyspark.sql import functions as dbf

dbf.to_geography(col=<col>)

パラメーター

パラメーター

Type

説明

col

pyspark.sql.Column または str

WKT または GeoJSON 形式の文字列値、または地理値を表す WKB 形式の BINARY 値。

パラメーター

Type

説明

col

pyspark.sql.Column または str

WKT または GeoJSON 形式の文字列値、または地理値を表す WKB 形式の BINARY 値。

Python
from pyspark.sql import functions as dbf
df = spark.createDataFrame([('POINT Z (3 4 5)',)], ['wkt'])
df.select(dbf.st_asewkt(dbf.to_geography('wkt')).alias('result')).collect()
Output
[Row(result='SRID=4326;POINT Z (3 4 5)')]
Python
from pyspark.sql import functions as dbf
df = spark.createDataFrame([('{"type":"MultiPoint","coordinates":[[3,4,5]]}',)], ['geojson'])
df.select(dbf.st_asewkt(dbf.to_geography('geojson')).alias('result')).collect()
Output
[Row(result='SRID=4326;MULTIPOINT Z ((3 4 5))')]
Python
from pyspark.sql import functions as dbf
df = spark.createDataFrame([(bytes.fromhex('01ef0300000100000001e9030000000000000000084000000000000010400000000000001440'),)], ['wkb'])
df.select(dbf.st_asewkt(dbf.to_geography('wkb')).alias('result')).collect()
Output
[Row(result='SRID=4326;GEOMETRYCOLLECTION Z (POINT Z (3 4 5))')]
このページの見出し