這很重要
這項功能目前處於 公開預覽版。
回傳一個二維點 幾何, 包含給定的 x 和 y 座標及 SRID 值。 若未提供 SRID 值,或 SRID 值為負數,則點幾何體的 SRID 值將設為 0。
關於對應的 Databricks SQL 函式,請參見 st_point 函數。
語法
from pyspark.databricks.sql import functions as dbf
dbf.st_point(col1=<col1>, col2=<col2>, col3=<col3>)
參數
| 參數 | 類型 | Description |
|---|---|---|
col1 |
pyspark.sql.Column 或浮動 |
點幾何的 X 座標。 |
col2 |
pyspark.sql.Column 或浮動 |
點幾何的Y座標。 |
col3 |
pyspark.sql.Column 或 int,選用 |
點幾何的 SRID 值。 |
範例
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([(1.0, 2.0, 4326,)], ['x', 'y', 'srid'])
df.select(dbf.st_asewkt(dbf.st_point('x', 'y', 'srid')).alias('result')).collect()
[Row(result='SRID=4326;POINT(1 2)')]
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([(1.0, 2.0,)], ['x', 'y'])
df.select(dbf.st_asewkt(dbf.st_point('x', 'y', 0)).alias('result')).collect()
[Row(result='POINT(1 2)')]
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([(1.0, 2.0, 0,)], ['x', 'y', 'srid'])
df.select(dbf.st_asewkt(dbf.st_point('x', 'y', 'srid')).alias('result')).collect()
[Row(result='POINT(1 2)')]
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([(1.0, 2.0,)], ['x', 'y'])
df.select(dbf.st_asewkt(dbf.st_point('x', 'y')).alias('result')).collect()
[Row(result='POINT(1 2)')]