적용 대상:
Databricks Runtime 18.1 이상에 해당합니다.
중요합니다
이 기능은 공개 미리보기 단계에 있습니다.
입력 지리 또는 기하 도형 값의 2D 프로젝션을 반환합니다.
출력 Geography 또는 Geometry 값의 SRID 값은 입력 값의 SRID 값과 같습니다.
입력이 None이면 함수가 None을 반환합니다.
해당 Databricks SQL 함수에 대해 알아보려면 st_force2d 함수를 참조하세요.
문법
from pyspark.databricks.sql import functions as dbf
dbf.st_force2d(col=<col>)
매개 변수
| 매개 변수 | 유형 | 설명 |
|---|---|---|
col |
pyspark.sql.Column 또는 str |
지리 또는 기하 도형 값입니다. |
Notes
입력에 Z 및/또는 M 좌표가 있는 경우 출력에서 삭제됩니다.
입력이 이미 2D이면 그대로 반환됩니다.
예제
점 지리에서 M 좌표를 삭제합니다.
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('POINT M (1 2 3)',)], ['wkt'])
df.select(dbf.st_asewkt(dbf.st_force2d(dbf.st_geogfromtext('wkt'))).alias('result')).collect()
[Row(result='SRID=4326;POINT(1 2)')]
멀티포인트 지리에서 Z 및 M 좌표를 삭제합니다.
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('MULTIPOINT ZM (EMPTY,0 0 10 20, 1 1 11 21)',)], ['wkt'])
df.select(dbf.st_asewkt(dbf.st_force2d(dbf.st_geogfromtext('wkt'))).alias('result')).collect()
[Row(result='SRID=4326;MULTIPOINT(EMPTY,(0 0),(1 1))')]
다각형 지리에서 Z 좌표를 삭제합니다.
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('POLYGON Z ((0 0 2,1 0 3,0 1 4,0 0 5))',)], ['wkt'])
df.select(dbf.st_asewkt(dbf.st_force2d(dbf.st_geogfromtext('wkt'))).alias('result')).collect()
[Row(result='SRID=4326;POLYGON((0 0,1 0,0 1,0 0))')]
점 기하 도형에서 Z 좌표를 삭제합니다.
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('POINT Z (1 2 3)',)], ['wkt'])
df.select(dbf.st_asewkt(dbf.st_force2d(dbf.st_geomfromtext('wkt', 4326))).alias('result')).collect()
[Row(result='SRID=4326;POINT(1 2)')]
줄 바꿈 기하 도형에서 Z 및 M 좌표를 삭제합니다.
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('LINESTRING ZM (0 0 10 20, 1 1 11 21)',)], ['wkt'])
df.select(dbf.st_asewkt(dbf.st_force2d(dbf.st_geomfromtext('wkt', 4326))).alias('result')).collect()
[Row(result='SRID=4326;LINESTRING(0 0,1 1)')]
입력 2D 기하 도형을 다음과 같이 반환합니다.
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('POINT(1 2)',)], ['wkt'])
df.select(dbf.st_asewkt(dbf.st_force2d(dbf.st_geomfromtext('wkt', 4326))).alias('result')).collect()
[Row(result='SRID=4326;POINT(1 2)')]
입력 지리의 SRID를 유지합니다.
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('POINT(1 2)',)], ['wkt'])
df.select(dbf.st_srid(dbf.st_force2d(dbf.st_geogfromtext('wkt'))).alias('result')).collect()
[Row(result=4326)]
입력 기하 도형의 SRID를 유지합니다.
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('POINT(1 2)',)], ['wkt'])
df.select(dbf.st_srid(dbf.st_force2d(dbf.st_geomfromtext('wkt', 4326))).alias('result')).collect()
[Row(result=4326)]
입력을 None로 받아 None을 반환합니다.
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([(None,)], ['wkt'])
df.select(dbf.st_force2d(dbf.st_geogfromtext('wkt')).alias('result')).collect()
[Row(result=None)]