| 303 | run_cmd(cmd) |
| 304 | |
| 305 | def flight_request(self, port, json_path=None, scenario_name=None): |
| 306 | cmd = ( |
| 307 | ['java'] + self._java_opts + [ |
| 308 | '-cp', _ARROW_FLIGHT_JAR, _ARROW_FLIGHT_CLIENT, '-port', str( |
| 309 | port) |
| 310 | ]) |
| 311 | |
| 312 | if json_path: |
| 313 | cmd.extend(('-j', json_path)) |
| 314 | elif scenario_name: |
| 315 | cmd.extend(('-scenario', scenario_name)) |
| 316 | else: |
| 317 | raise TypeError('Must provide one of json_path or scenario_name') |
| 318 | |
| 319 | if self.debug: |
| 320 | log(' '.join(cmd)) |
| 321 | run_cmd(cmd) |
| 322 | |
| 323 | @contextlib.contextmanager |
| 324 | def flight_server(self, scenario_name=None): |