Sdílet prostřednictvím


h3_kringdistances

Vrátí všechna ID buněk H3 (reprezentovaná jako dlouhá celá čísla nebo řetězce) ve vzdálenosti mřížky k od ID buňky H3 původu spolu s jejich vzdáleností od ID buňky H3 původu. Přesněji řečeno je výsledkem pole struktur, kde každá struktura obsahuje ID buňky H3 (reprezentované jako dlouhé celé číslo nebo řetězec) a jeho vzdálenost od ID buňky H3 původu. Typ ID buněk H3 ve výstupu je stejný jako typ vstupního ID buňky H3 (první argument výrazu). Podporuje Spark Connect.

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

Syntaxe

from pyspark.databricks.sql import functions as dbf

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

Parametry

Parameter Typ Description
col1 pyspark.sql.Column nebo str ID buňky H3 reprezentované jako sloupec nebo řetězec
col2 pyspark.sql.Column, str nebo int Maximální vzdálenost mřížky od ID buňky H3 (první argument).

Examples

from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([(599686042433355775, '85283473fffffff', 1,),],['h3l', 'h3s', 'res'])
df.select(dbf.h3_kringdistances('h3l', 'res').alias('result')).collect()
[Row(result=[Row(cellid=599686042433355775, distance=0),     Row(cellid=599686030622195711, distance=1), Row(cellid=599686044580839423, distance=1),     Row(cellid=599686038138388479, distance=1), Row(cellid=599686043507097599, distance=1),     Row(cellid=599686015589810175, distance=1), Row(cellid=599686014516068351, distance=1)])]
df.select(dbf.h3_kringdistances('h3s', 'res').alias('result')).collect()
[Row(result=[Row(cellid='85283473fffffff', distance=0),     Row(cellid='85283447fffffff', distance=1), Row(cellid='8528347bfffffff', distance=1),     Row(cellid='85283463fffffff', distance=1), Row(cellid='85283477fffffff', distance=1),     Row(cellid='8528340ffffffff', distance=1), Row(cellid='8528340bfffffff', distance=1)])]