try_to_geography
info
Aperçu
Cette fonctionnalité est en aperçu public.
Analyse la valeur binaire ou de chaîne d'entrée et renvoie la valeur Geography correspondante. None est renvoyé si l'entrée n'est pas valide.
Pour la fonction Databricks SQL correspondante, consultez la fonctiontry_to_geography.
Syntaxe
Python
from pyspark.sql import functions as dbf
dbf.try_to_geography(col=<col>)
parameter
parameter | Type | Description |
|---|---|---|
|
| Une valeur de chaîne au format WKT ou GeoJSON, ou une valeur BINARY au format WKB représentant une valeur de Géographie. |
Exemples
Python
from pyspark.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()
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.try_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.try_to_geography('wkb')).alias('result')).collect()
Output
[Row(result='SRID=4326;GEOMETRYCOLLECTION Z (POINT Z (3 4 5))')]
Python
from pyspark.sql import functions as dbf
df = spark.createDataFrame([('invalid wkt',)], ['wkt'])
df.select(dbf.st_asewkt(dbf.try_to_geography('wkt')).alias('result')).collect()
Output
[Row(result=None)]