Sdílet prostřednictvím


zkusit_k_geografii

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. None je vrácena, pokud je vstup neplatný.

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

Syntaxe

from pyspark.databricks.sql import functions as dbf

dbf.try_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.try_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.try_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.try_to_geography('wkb')).alias('result')).collect()
[Row(result='SRID=4326;GEOMETRYCOLLECTION Z (POINT Z (3 4 5))')]
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('invalid wkt',)], ['wkt'])
df.select(dbf.st_asewkt(dbf.try_to_geography('wkt')).alias('result')).collect()
[Row(result=None)]