- DataFrame.write_csv(root_dir: Union[str, pathlib.Path], partition_cols: Optional[List[Union[daft.expressions.expressions.Expression, str]]] = None) daft.dataframe.dataframe.DataFrame [source]#
Writes the DataFrame as CSV files, returning a new DataFrame with paths to the files that were written
Files will be written to
<root_dir>/*with randomly generated UUIDs as the file names.
Currently generates a csv file per partition unless
partition_colsare used, then the number of files can equal the number of partitions times the number of values of partition col.
This call is blocking and will execute the DataFrame when called
root_dir (str) – root file path to write parquet files to.
compression (str, optional) – compression algorithm. Defaults to “snappy”.
partition_cols (Optional[List[ColumnInputType]], optional) – How to subpartition each partition further. Currently only supports Column Expressions with any calls. Defaults to None.
The filenames that were written out as strings.
- Return type