Runs the Impala shell on the commandline. 'shell_args' is a string which represents the commandline options. Returns a ImpalaShellResult. Does not assert based on success or failure of command.
(vector, shell_args, env=None, stdin_input=None,
wait_until_connected=True, stdout_file=None,
stderr_file=None)
| 141 | |
| 142 | |
| 143 | def run_impala_shell_cmd_no_expect(vector, shell_args, env=None, stdin_input=None, |
| 144 | wait_until_connected=True, stdout_file=None, |
| 145 | stderr_file=None): |
| 146 | """Runs the Impala shell on the commandline. |
| 147 | |
| 148 | 'shell_args' is a string which represents the commandline options. |
| 149 | Returns a ImpalaShellResult. |
| 150 | |
| 151 | Does not assert based on success or failure of command. |
| 152 | """ |
| 153 | # Only wait_until_connected if we also have input to send. Otherwise expect that |
| 154 | # the command will run without input and exit. Avoid waiting as ImpalaShell may |
| 155 | # exit before it can detect there is a successful connection and assert False. |
| 156 | p = ImpalaShell(vector, shell_args, env=env, |
| 157 | wait_until_connected=wait_until_connected and stdin_input, |
| 158 | stdout_file=stdout_file, stderr_file=stderr_file) |
| 159 | result = p.get_result(stdin_input) |
| 160 | return result |
| 161 | |
| 162 | |
| 163 | def get_impalad_host_port(vector): |