Reads the CSV file into memory using pyarrow's open_csv csv The CSV bytes args Positional arguments to be forwarded to pyarrow's open_csv kwargs Keyword arguments to be forwarded to pyarrow's open_csv
(self, csv, *args, **kwargs)
| 1582 | class BaseStreamingCSVRead(BaseTestCSV): |
| 1583 | |
| 1584 | def open_csv(self, csv, *args, **kwargs): |
| 1585 | """ |
| 1586 | Reads the CSV file into memory using pyarrow's open_csv |
| 1587 | csv The CSV bytes |
| 1588 | args Positional arguments to be forwarded to pyarrow's open_csv |
| 1589 | kwargs Keyword arguments to be forwarded to pyarrow's open_csv |
| 1590 | """ |
| 1591 | read_options = kwargs.setdefault('read_options', ReadOptions()) |
| 1592 | read_options.use_threads = self.use_threads |
| 1593 | return open_csv(csv, *args, **kwargs) |
| 1594 | |
| 1595 | def open_bytes(self, b, **kwargs): |
| 1596 | return self.open_csv(pa.py_buffer(b), **kwargs) |
no test coverage detected