Nuta
Dostęp do tej strony wymaga autoryzacji. Możesz spróbować się zalogować lub zmienić katalog.
Dostęp do tej strony wymaga autoryzacji. Możesz spróbować zmienić katalogi.
Zwraca tablicę identyfikatorów komórek H3 reprezentowanych jako ciągi, które odpowiadają sześciokątom lub pentagonom o określonej rozdzielczości, w minimalny sposób pokrywających liniową lub powierzchniową geografię wejściową. Wyrażenie zgłasza błąd, jeśli geografia nie jest liniowa (linestring lub multilinestring) ani powierzchniowa (polygon lub multipolygon), lub jeśli podczas analizowania wejściowej reprezentacji geograficznej wystąpi błąd.
Dopuszczalne reprezentacje wejściowe to WKT, GeoJSON i WKB. W pierwszych dwóch przypadkach dane wejściowe powinny być typu ciąg, natomiast w ostatnim przypadku dane wejściowe mają być typu Binary. Obsługuje program Spark Connect.
Aby uzyskać odpowiednią funkcję SQL usługi Databricks, zobacz h3_coverash3string funkcja.
Składnia
from pyspark.databricks.sql import functions as dbf
dbf.h3_coverash3string(col1=<col1>, col2=<col2>)
Parametry
| Parameter | Typ | Description |
|---|---|---|
col1 |
pyspark.sql.Column lub str |
Ciąg reprezentujący liniową lub arealną lokalizację geograficzną w systemie odniesienia współrzędnych WGS84 w formacie WKT lub GeoJSON albo plik BINARNY reprezentujący liniową lub arealną lokalizację geograficzną w systemie odniesienia współrzędnych WGS84 w formacie WKB. |
col2 |
pyspark.sql.Column, str lub int |
Rozdzielczość identyfikatorów komórek H3, które obejmują obszar geograficzny. |
Przykłady
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_coverash3string('wkt', 'res').alias('result')).collect()
[Row(result=['8126fffffffffff', '81283ffffffffff', '8129bffffffffff', '812a3ffffffffff', '812abffffffffff', '8148fffffffffff', '81263ffffffffff', '81267ffffffffff', '8126bffffffffff'])]