Udostępnij przez


h3_uncompact

Rozpakowuje zestaw wejściowych identyfikatorów komórek H3 do określonej rozdzielczości. Obsługuje program Spark Connect.

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

Składnia

from pyspark.databricks.sql import functions as dbf

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

Parametry

Parameter Typ Description
col1 pyspark.sql.Column lub str Tablica identyfikatorów komórek H3 (reprezentowane jako liczby całkowite lub ciągi znaków) do rozkompaktowania.
col2 pyspark.sql.Column, str lub int Rozdzielczość nieskompilowanych identyfikatorów komórek H3.

Przykłady

from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([([599686030622195711, 599686015589810175, 599686014516068351,599686034917163007, 599686029548453887, 599686032769679359, 599686198125920255,599686023106002943, 599686027400970239, 599686013442326527, 599686012368584703,599686018811035647, 595182446027210751], 5,)], ['h3l_array', 'res'])
df.select(dbf.h3_uncompact('h3l_array', 'res').alias('result')).collect()
[Row(result=[599686030622195711, 599686015589810175, 599686014516068351, 599686034917163007,     599686029548453887, 599686032769679359, 599686198125920255, 599686023106002943,     599686027400970239, 599686013442326527, 599686012368584703, 599686018811035647,     599686038138388479, 599686039212130303, 599686040285872127, 599686041359613951,     599686042433355775, 599686043507097599, 599686044580839423])]
df.select(dbf.h3_uncompact('h3l_array', 5).alias('result')).collect()
[Row(result=[599686030622195711, 599686015589810175, 599686014516068351, 599686034917163007,     599686029548453887, 599686032769679359, 599686198125920255, 599686023106002943,     599686027400970239, 599686013442326527, 599686012368584703, 599686018811035647,     599686038138388479, 599686039212130303, 599686040285872127, 599686041359613951,     599686042433355775, 599686043507097599, 599686044580839423])]