Sdílet prostřednictvím


h3_try_coverash3string

Vrátí pole ID buněk H3 reprezentované jako řetězce, které odpovídají šestiúhelníku nebo pětiúhelníku zadaného rozlišení, které minimálně pokrývají vstupní lineární nebo areální geografii. Výraz vrátí None , pokud zeměpis není lineární (linestring nebo multilinestring), areální (mnohoúhelník nebo multipolygon) nebo pokud se při analýze vstupu najde chyba. Výraz vrátí chybu, pokud je vstupní rozlišení neplatné. Přijatelné vstupní reprezentace jsou WKT, GeoJSON a WKB. V prvních dvou případech se očekává, že vstup bude typu řetězec, zatímco v posledním případě se očekává, že vstup bude typu BINARY.

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

Syntaxe

from pyspark.databricks.sql import functions as dbf

dbf.h3_try_coverash3string(col1=<col1>, col2=<col2>)

Parametry

Parameter Typ Description
col1 pyspark.sql.Column nebo str Řetězec představující lineární nebo areální geografii v referenčním systému souřadnic WGS84 ve formátu WKT nebo GeoJSON nebo BINARY představující lineární nebo areální geografii v referenčním systému souřadnic WGS84 ve formátu WKB.
col2 pyspark.sql.Column, str nebo int Rozlišení ID buněk H3 pokrývajících geografickou oblast.

Examples

from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('POLYGON((-122.4194 37.7749,-118.2437 34.0522,-74.0060 40.7128,-122.4194 37.7749))', 1),],['wkt', 'res'])
df.select(dbf.h3_try_coverash3string('wkt', 'res').alias('result')).collect()
[Row(result=['8126fffffffffff', '81283ffffffffff', '8129bffffffffff', '812a3ffffffffff',     '812abffffffffff', '8148fffffffffff', '81263ffffffffff', '81267ffffffffff', '8126bffffffffff'])]
df_invalid = spark.createDataFrame([('invalid input', 1),], ['wkt', 'res'])
df_invalid.select(dbf.h3_try_coverash3string('wkt', 'res').alias('result')).collect()
[Row(result=None)]