st_addpoint

Önemli

Bu özellik Genel Önizleme aşamasındadır. Önizlemeler sayfasında önizleme kaydını onaylayabilirsiniz. Bkz. Azure Databricks önizlemelerini yönetme.

Giriş linestring Geography veya Geometry içindeki n. konuma yeni bir nokta ekler.

İlgili Databricks SQL fonksiyonu için, bkz. st_addpoint işlev.

Sözdizimi

from pyspark.databricks.sql import functions as dbf

dbf.st_addpoint(col1=<col1>, col2=<col2>, col3=<col3>)

Parametreler

Parametre	Türü	Description
col1	pyspark.sql.Column veya str	Bir çizgi dizisini temsil eden Coğrafya veya Geometri değeri.
col2	pyspark.sql.Column veya str	Bir noktayı temsil eden Coğrafya veya Geometri değeri.
col3	pyspark.sql.Column veya intveya isteğe bağlı	Çizgi dizisinde yeni noktanın eklenmesi gereken 1 tabanlı isteğe bağlı bir konum. Varsayılan değer -1'dir.

Örnekler

from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('LINESTRING(1 2,3 4)','POINT(7 8)',)], ['wkt1', 'wkt2'])
df.select(dbf.st_astext(dbf.st_addpoint(dbf.st_geogfromtext('wkt1'), dbf.st_geogfromtext('wkt2'), 3)).alias('result')).collect()

[Row(result='LINESTRING(1 2,3 4,7 8)')]

from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('LINESTRING(1 2,3 4)','POINT(7 8)',)], ['wkt1', 'wkt2'])
df.select(dbf.st_asewkt(dbf.st_addpoint(dbf.st_geogfromtext('wkt1'), dbf.st_geogfromtext('wkt2'))).alias('result')).collect()

[Row(result='SRID=4326;LINESTRING(1 2,3 4,7 8)')]

from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('LINESTRING ZM (1 2 3 4,5 6 7 8)','POINT M (0 9 99)',)], ['wkt1', 'wkt2'])
df.select(dbf.st_asewkt(dbf.st_addpoint(dbf.st_geogfromtext('wkt1'), dbf.st_geogfromtext('wkt2'), -1)).alias('result')).collect()

[Row(result='SRID=4326;LINESTRING ZM (1 2 3 4,5 6 7 8,0 9 0 99)')]