メインコンテンツまでスキップ

h3_pointash3

指定された解像度で指定されたポイントに対応するH3 セル ID ( intとして) を返します。地理がポイントでない場合、または地理の入力表現を解析するときにエラーが見つかった場合、式はエラーを出力します。許容される入力表現は、WKT、GeoJSON、および WKB です。最初の 2 つのケースでは入力は文字列型であることが期待されますが、最後のケースでは入力は BINARY 型であることが期待されます。Spark Connect をサポートします。

対応する Databricks SQL 関数については、 h3_pointash3関数を参照してください。

構文

Python
from pyspark.databricks.sql import functions as dbf

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

パラメーター

パラメーター

Type

説明

col1

pyspark.sql.Column または str

WKT または GeoJSON 形式の WGS84 座標参照システムのポイント地理を表す文字列、または WKB 形式の WGS84 座標参照システムの地理を表す BINARY。

col2

pyspark.sql.Columnstr 、または int

点の地理に対応するコンピュートしたい H3 セル ID の解像度。

Python
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('POINT(-122.4783 37.8199)', 13),], ['wkt', 'res'])
df.select(dbf.h3_pointash3('wkt', 'res').alias('result')).collect()
Output
[Row(result=635714569676958015)]
Python
df.select(dbf.h3_pointash3('wkt', 13).alias('result')).collect()
Output
[Row(result=635714569676958015)]