sedona_read_wkb: Create a SpatialRDD from a Well-Known Binary (WKB) data...
In r-spark/sparklyr.sedona: Sparklyr Extension for Apache Sedona

Description Usage Arguments See Also Examples

Create a generic SpatialRDD from a hex-encoded Well-Known Binary (WKB) data source.

sedona_read_wkb(
  sc,
  location,
  wkb_col_idx = 0L,
  allow_invalid_geometries = TRUE,
  skip_syntactically_invalid_geometries = TRUE,
  storage_level = "MEMORY_ONLY",
  repartition = 1L
)

`sc`	A `spark_connection`.
`location`	Location of the data source.
`wkb_col_idx`	Zero-based index of column containing hex-encoded WKB data (default: 0).
`allow_invalid_geometries`	Whether to allow topology-invalid geometries to exist in the resulting RDD.
`skip_syntactically_invalid_geometries`	Whether to allows Sedona to automatically skip syntax-invalid geometries, rather than throwing errorings.
`storage_level`	Storage level of the RDD (default: MEMORY_ONLY).
`repartition`	The minimum number of partitions to have in the resulting RDD (default: 1).

Other Sedona data inferface functions: sedona_read_dsv_to_typed_rdd(), sedona_read_geojson_to_typed_rdd(), sedona_read_geojson(), sedona_read_shapefile(), sedona_read_wkt(), sedona_save_spatial_rdd(), sedona_write_geojson(), sedona_write_wkb(), sedona_write_wkt()

library(sparklyr)
library(sparklyr.sedona)

sc <- spark_connect(master = "spark://HOST:PORT")

if (!inherits(sc, "test_connection")) {
  input_location <- system.file(
    file.path("extdata", "county_tiny_wkb.tsv"), package = "sparklyr.sedona"
  )
  rdd <- sedona_read_wkb(
    sc, location = input_location, wkb_col_idx = 0L
  )
}