Method write

tools/distpartitioning/array_readwriter/csv.py:29–39

(self, path, arr)

        return arr.to_pandas().to_numpy()

    def write(self, path, arr):
        logging.debug(
            "Writing to %s using CSV format with configuration %s"
            % (path, self.__dict__)
        )
        write_options = pyarrow.csv.WriteOptions(
            include_header=False, delimiter=self.delimiter
        )
        arr = pyarrow.Table.from_pandas(pd.DataFrame(arr))
        pyarrow.csv.write_csv(arr, path, write_options=write_options)
        logging.debug("Done writing to %s" % path)