Writes the data from a data source to a directory of NDJSON files. The files will be named using the resource type and the ".ndjson" extension.
ds_write_ndjson(ds, path, save_mode = SaveMode$ERROR, file_name_mapper = NULL)
No return value, called for side effects only.
Pathling documentation - Writing NDJSON
Other data sink functions:
ds_write_delta()
,
ds_write_parquet()
,
ds_write_tables()
pc <- pathling_connect()
#> Warning: 2 arguments not used by format 'spark-3.5.3-bin-hadoop3'
data_source <- pc %>% pathling_read_ndjson(pathling_examples('ndjson'))
# Write the data to a directory of NDJSON files.
data_source %>% ds_write_ndjson(file.path(tempdir(), 'ndjson'))
pathling_disconnect(pc)