(self, path)
| 132 | return pa.BufferReader(data) |
| 133 | |
| 134 | def open_input_file(self, path): |
| 135 | if "notfound" in path: |
| 136 | raise FileNotFoundError(path) |
| 137 | data = f"{path}:input_file".encode('utf8') |
| 138 | return pa.BufferReader(data) |
| 139 | |
| 140 | def open_output_stream(self, path, metadata): |
| 141 | if "notfound" in path: |
no test coverage detected