Create a DataFrame from one or more Parquet files

The query will only be executed when requested.

sd_read_parquet(
  path,
  options = NULL,
  geometry_columns = NULL,
  validate = FALSE,
  partitioning = NULL
)

sd_ctx_read_parquet(
  ctx,
  path,
  options = NULL,
  geometry_columns = NULL,
  validate = FALSE,
  partitioning = NULL
)

Arguments

path

One or more paths or URIs to Parquet files

options

A named list of options to pass to the Parquet reader.

geometry_columns

A JSON string or named list mapping column names to GeoParquet column metadata. This can be used to mark binary WKB columns as geometry columns or override existing GeoParquet metadata. The suggested jsonlite package is required when passing a list.

validate

Whether to validate geometry column contents against their metadata. Currently, this validates WKB input.

partitioning

A character vector of column names for hive-style partitioning. By default (NULL), partition columns are auto-discovered. Use character() to disable partitioning.

ctx

A SedonaDB context.

Value

A sedonadb_dataframe

Examples

path <- system.file("files/natural-earth_cities_geo.parquet", package = "sedonadb")
sd_read_parquet(path) |> head(5) |> sd_preview()
#> <sedonab_dataframe: ?? x 2>
#> ┌──────────────┬───────────────────────────────┐
#> │     name     ┆            geometry           │
#> │     utf8     ┆            geometry           │
#> ╞══════════════╪═══════════════════════════════╡
#> │ Vatican City ┆ POINT(12.4533865 41.9032822)  │
#> ├╌╌╌╌╌╌╌╌╌╌╌╌╌╌┼╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌┤
#> │ San Marino   ┆ POINT(12.4417702 43.9360958)  │
#> ├╌╌╌╌╌╌╌╌╌╌╌╌╌╌┼╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌┤
#> │ Vaduz        ┆ POINT(9.5166695 47.1337238)   │
#> ├╌╌╌╌╌╌╌╌╌╌╌╌╌╌┼╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌┤
#> │ Lobamba      ┆ POINT(31.1999971 -26.4666675) │
#> ├╌╌╌╌╌╌╌╌╌╌╌╌╌╌┼╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌┤
#> │ Luxembourg   ┆ POINT(6.1300028 49.6116604)   │
#> └──────────────┴───────────────────────────────┘
#> Preview of up to 6 row(s)