library(sparklyr)
library(apache.sedona)
sc <- spark_connect(master = "spark://HOST:PORT")
if (!inherits(sc, "test_connection")) {
tbl <- dplyr::tbl(
sc,
dplyr::sql("SELECT ST_GeomFromText('POINT(-71.064544 42.28787)') AS `pt`")
)
sedona_save_spatial_rdd(
tbl %>% dplyr::mutate(id = 1),
spatial_col = "pt",
output_location = "/tmp/pts.wkb",
output_format = "wkb"
)
}
Run the code above in your browser using DataLab