Reads the JSON file into memory using pyarrow's open_json json The JSON bytes args Positional arguments to be forwarded to pyarrow's open_json kwargs Keyword arguments to be forwarded to pyarrow's open_json
(self, json, *args, **kwargs)
| 368 | |
| 369 | class BaseTestStreamingJSONRead(BaseTestJSON): |
| 370 | def open_json(self, json, *args, **kwargs): |
| 371 | """ |
| 372 | Reads the JSON file into memory using pyarrow's open_json |
| 373 | json The JSON bytes |
| 374 | args Positional arguments to be forwarded to pyarrow's open_json |
| 375 | kwargs Keyword arguments to be forwarded to pyarrow's open_json |
| 376 | """ |
| 377 | read_options = kwargs.setdefault('read_options', ReadOptions()) |
| 378 | read_options.use_threads = self.use_threads |
| 379 | return open_json(json, *args, **kwargs) |
| 380 | |
| 381 | def open_bytes(self, b, **kwargs): |
| 382 | return self.open_json(pa.py_buffer(b), **kwargs) |
no test coverage detected