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. Une erreur est levée pour une entrée non valide.
Pour la fonction Databricks SQL correspondante, consultez la fonctionto_geography.
Syntaxe
Python
from pyspark.sql import functions as dbf
dbf.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.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))')]