입력된 선형 또는 면적 지리를 최소한의 면적으로 덮는, 지정된 해상도의 육각형이나 오각형에 해당하는 H3 셀 ID의 배열을 긴 정수로 표현하여 반환합니다. 이 식은 지리가 라인스트링 또는 멀티라인스트링, 폴리곤 또는 멀티폴리곤이 아니거나 입력을 파싱할 때 오류가 발견되면 None 를 반환합니다. 입력 해상도가 잘못된 경우 식이 오류를 반환합니다. 지리의 표현입니다.
허용되는 입력 표현은 WKT, GeoJSON 및 WKB입니다. 처음 두 경우에서 입력은 문자열 형식인 반면, 마지막 경우에는 입력이 BINARY 형식이어야 합니다.
해당 Databricks SQL 함수에 대해 알아보려면 h3_try_coverash3 함수를 참조하세요.
문법
from pyspark.databricks.sql import functions as dbf
dbf.h3_try_coverash3(col1=<col1>, col2=<col2>)
매개 변수
| 매개 변수 | 유형 | Description |
|---|---|---|
col1 |
pyspark.sql.Column 또는 str |
WGS84 좌표 참조 시스템에서 WKT 또는 GeoJSON 형식의 선형 또는 면적 지리를 나타내는 문자열이거나, WKB 형식으로 WGS84 좌표 참조 시스템의 선형 또는 면적 지리를 나타내는 바이너리입니다. |
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))', 1),],['wkt', 'res'])
df.select(dbf.h3_try_coverash3('wkt', 'res').alias('result')).collect()
[Row(result=[581650447186526207, 581672437419081727, 581698825698148351, 581707621791170559, 581716417884192767, 582248581512036351, 581637253046992895, 581641651093503999, 581646049140015103])]
df_invalid = spark.createDataFrame([('invalid input', 1),], ['wkt', 'res'])
df_invalid.select(dbf.h3_try_coverash3('wkt', 'res').alias('result')).collect()
[Row(result=None)]