Important
この機能は パブリック プレビュー段階です。
入力された Geography または Geometry の値 を WKB 形式で返します。
対応する Databricks SQL 関数については、 st_aswkb 関数を参照してください。
構文
from pyspark.databricks.sql import functions as dbf
dbf.st_aswkb(col1=<col1>, col2=<col2>)
パラメーター
| パラメーター | タイプ | Description |
|---|---|---|
col1 |
pyspark.sql.Column または str |
地理空間値 ( Geography または Geometry)。 |
col2 |
pyspark.sql.Column または str、省略可能 |
出力 WKB の省略可能なエンディアン。リトル エンディアン (既定) またはビッグ エンディアンの場合はNDRXDR。 |
例示
from pyspark.databricks.sql import functions as dbf
from pyspark.sql.functions import hex
df = spark.createDataFrame([('LINESTRING(1 2,3 4)',)], ['wkt'])
df.select(hex(dbf.st_aswkb(dbf.st_geogfromtext('wkt'))).alias('result')).collect()
[Row(result='010200000002000000000000000000F03F000000000000004000000000000008400000000000001040')]
from pyspark.databricks.sql import functions as dbf
from pyspark.sql.functions import hex
df = spark.createDataFrame([('LINESTRING(1 2,3 4)', 'NDR',)], ['wkt', 'e'])
df.select(hex(dbf.st_aswkb(dbf.st_geogfromtext('wkt'), df.e)).alias('result')).collect()
[Row(result='010200000002000000000000000000F03F000000000000004000000000000008400000000000001040')]
from pyspark.databricks.sql import functions as dbf
from pyspark.sql.functions import hex
df = spark.createDataFrame([('LINESTRING(1 2,3 4)',)], ['wkt'])
df.select(hex(dbf.st_aswkb(dbf.st_geogfromtext('wkt'), 'XDR')).alias('result')).collect()
[Row(result='0000000002000000023FF0000000000000400000000000000040080000000000004010000000000000')]