Writes the data from a data source to a directory of Parquet files.
ds_write_parquet(ds, path, save_mode = SaveMode$ERROR)The DataSource object.
The URI of the directory to write the files to.
The save mode to use when writing the data.
No return value, called for side effects only.
Pathling documentation - Writing Parquet
Other data sink functions:
ds_write_delta(),
ds_write_ndjson(),
ds_write_tables()
pc <- pathling_connect()
data_source <- pc %>% pathling_read_ndjson(pathling_examples('ndjson'))
# Write the data to a directory of Parquet files.
data_source %>% ds_write_parquet(file.path(tempdir(), 'parquet'))
pathling_disconnect(pc)