h3_try_coverash3

Vrátí matici ID buněk H3 reprezentovaných jako dlouhá celá čísla odpovídající š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é. reprezentace zeměpisu.

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_coverash3.

Syntaxe

from pyspark.databricks.sql import functions as dbf

dbf.h3_try_coverash3(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_coverash3('wkt', 'res').alias('result')).collect()

[Row(result=[581650447186526207, 581672437419081727, 581698825698148351, 581707621791170559,     581716417884192767, 582248581512036351, 581637253046992895, 581641651093503999,     581646049140015103])]

df_invalid = spark.createDataFrame([('invalid input', 1),], ['wkt', 'res'])
df_invalid.select(dbf.h3_try_coverash3('wkt', 'res').alias('result')).collect()

[Row(result=None)]