Udostępnij przez


h3_polyfillash3string

Zwraca tablicę identyfikatorów komórek H3, reprezentowanych jako ciągi znaków, odpowiadających sześciokątom lub pentagonom o określonej rozdzielczości, zawartych w podanej geograficznie przestrzeni wejściowej. Określanie pokrycia jest ustalane przez centroidy komórek: komórka jest uważana za pokrywającą obszar geograficzny, jeśli centroid komórki leży wewnątrz tego obszaru geograficznego. Wyrażenie zwraca błąd, jeśli geografia nie jest obszarowa (wielobok lub wielobok złożony) lub jeśli podczas analizowania reprezentacji wejściowej geografii pojawi się błąd. Dopuszczalne reprezentacje wejściowe to WKT, GeoJSON i WKB. W pierwszych dwóch przypadkach dane wejściowe powinny być ciągiem znaków, natomiast w ostatnim przypadku dane wejściowe powinny być typu binarnego. Obsługuje program Spark Connect.

Aby uzyskać odpowiednią funkcję SQL usługi Databricks, zobacz h3_polyfillash3string funkcja.

Składnia

from pyspark.databricks.sql import functions as dbf

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

Parametry

Parameter Typ Description
col1 pyspark.sql.Column lub str Ciąg reprezentujący lokalizację geograficzną w systemie odniesienia współrzędnych WGS84 w formacie WKT lub GeoJSON albo plik BINARNY reprezentujący 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))', 2),],
... ['wkt', 'res'])
df.select(dbf.h3_polyfillash3string('wkt', 'res').alias('result')).collect()
[Row(result=['82268ffffffffff', '82269ffffffffff', '822987fffffffff', '8226e7fffffffff',     '822997fffffffff', '8226f7fffffffff', '822657fffffffff', '8229affffffffff'])]