Method
stream_to_file
(self, stream_path, file_path)
Source from the content-addressed store, hash-verified
| 275 | return self._run(arrow_path, json_path, 'JSON_TO_ARROW') |
| 276 | |
| 277 | def stream_to_file(self, stream_path, file_path): |
| 278 | cmd = ( |
| 279 | ['java'] + self._java_opts + [ |
| 280 | '-cp', |
| 281 | _ARROW_TOOLS_JAR, |
| 282 | 'org.apache.arrow.tools.StreamToFile', |
| 283 | stream_path, |
| 284 | file_path, |
| 285 | ] |
| 286 | ) |
| 287 | if self.debug: |
| 288 | log(' '.join(cmd)) |
| 289 | run_cmd(cmd) |
| 290 | |
| 291 | def file_to_stream(self, file_path, stream_path): |
| 292 | cmd = ( |
Callers
nothing calls this directly
Tested by
no test coverage detected