共用方式為


h3_coverash3

回傳一組以長整數表示的 H3 格子 ID 陣列,對應於指定解析度的六角形或五邊形,這些元素至少涵蓋輸入的線性或面積地理。 若地理資料不是線性(線串或多線串)、區域型(多邊形或多多邊形),或在解析輸入地理表示時發現錯誤,則該表達式會產生錯誤。

可接受的輸入表示方式包括 WKTGeoJSONWKB。 前兩種情況下,輸入預期為字串型,而最後一種則預期為二進位型。 支援 Spark Connect。

關於對應的 Databricks SQL 函式,請參見 h3_coverash3 函數

語法

from pyspark.databricks.sql import functions as dbf

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

參數

參數 類型 Description
col1 pyspark.sql.Columnstr 一個字串代表 WGS84 座標參考系統中線性或面積地理的字串(WKT 或 GeoJSON 格式),或一個二進位代表 WGS84 座標參考系統中線性或區域地理的字串(WKB 格式)。
col2 pyspark.sql.Column、str 或 int 涵蓋地理範圍的 H3 cell ID 解析度。

範例

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_coverash3('wkt', 'res').alias('result')).collect()
[Row(result=[581650447186526207, 581672437419081727, 581698825698148351, 581707621791170559,     581716417884192767, 582248581512036351, 581637253046992895, 581641651093503999,     581646049140015103])]