Sdílet prostřednictvím


to_geography

Důležité

Tato funkce je ve verzi Public Preview.

Parsuje vstupní binární nebo řetězcovou hodnotu a vrátí odpovídající zeměpisnou hodnotu. Pro neplatný vstup se vyvolá chyba.

Odpovídající funkci SQL Databricks vizte funkceto_geography.

Syntaxe

from pyspark.databricks.sql import functions as dbf

dbf.to_geography(col=<col>)

Parametry

Parameter Typ Description
col pyspark.sql.Column nebo str Řetězcová hodnota ve formátu WKT nebo GeoJSON nebo BINÁRNÍ hodnota ve formátu WKB představující zeměpisnou hodnotu.

Examples

from pyspark.databricks.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()
[Row(result='SRID=4326;POINT Z (3 4 5)')]
from pyspark.databricks.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()
[Row(result='SRID=4326;MULTIPOINT Z ((3 4 5))')]
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([(bytes.fromhex('01ef0300000100000001e9030000000000000000084000000000000010400000000000001440'),)], ['wkb'])
df.select(dbf.st_asewkt(dbf.to_geography('wkb')).alias('result')).collect()
[Row(result='SRID=4326;GEOMETRYCOLLECTION Z (POINT Z (3 4 5))')]