指定した解像度で指定されたポイントに対応する H3 セル ID (文字列) を返します。 geography がポイントでない場合、または geography の入力表現を解析するときにエラーが見つかった場合、式はエラーを出力します。 許容される入力表現は、WKT、GeoJSON、WKB です。 最初の 2 つのケースでは、入力は文字列型であることが想定されますが、最後のケースでは、入力は BINARY 型であることが予想されます。 Spark Connect をサポートします。
対応する Databricks SQL 関数については、 h3_pointash3string 関数を参照してください。
構文
from pyspark.databricks.sql import functions as dbf
dbf.h3_pointash3string(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([('POINT(-122.4783 37.8199)', 13),], ['wkt', 'res'])
df.select(dbf.h3_pointash3string('wkt', 'res').alias('result')).collect()
[Row(result='8d283087022a93f')]
df.select(dbf.h3_pointash3string('wkt', 13).alias('result')).collect()
[Row(result='8d283087022a93f')]