長整数として表される H3 セル ID の配列を返します。これは、入力の地理的位置に含まれる指定した解像度の六角形または五角形に対応します。 コンテインメントは、セルの重心によって決定されます。セルの重心がエリア地理内にある場合、セルは地理をカバーすると見なされます。 この式は、geography が areal (多角形またはマルチポリゴン) でない場合、または geography の入力表現を解析するときにエラーが見つかった場合にエラーを出力します。 許容される入力表現は、WKT、GeoJSON、WKB です。 最初の 2 つのケースでは、入力は文字列型であることが想定されますが、最後のケースでは、入力は BINARY 型であることが予想されます。 Spark Connect をサポートします。
対応する Databricks SQL 関数については、 h3_polyfillash3 関数を参照してください。
構文
from pyspark.databricks.sql import functions as dbf
dbf.h3_polyfillash3(col1=<col1>, col2=<col2>)
パラメーター
| パラメーター | タイプ | Description |
|---|---|---|
col1 |
pyspark.sql.Column または str |
WKT 形式または GeoJSON 形式の WGS84 座標参照システムの地理を表す文字列、または WKB 形式の WGS84 座標参照システムの地理を表す BINARY。 |
col2 |
pyspark.sql.Column、str、または int |
地理をカバーする H3 セル 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))', 2),],
... ['wkt', 'res'])
df.select(dbf.h3_polyfillash3('wkt', 'res').alias('result')).collect()
[Row(result=[586146350232502271, 586147449744130047, 586198577034821631, 586152397546455039, 586199676546449407, 586153497058082815, 586142501941805055, 586201325813891071])]