Execute the query 'query_str' asynchronously on the server with options dictionary 'set_query_options' and return a query handle that can be used for subsequent ImpalaClient method calls for the query.
(self, query_str, set_query_options)
| 1347 | return query |
| 1348 | |
| 1349 | def execute_query(self, query_str, set_query_options): |
| 1350 | """Execute the query 'query_str' asynchronously on the server with options dictionary |
| 1351 | 'set_query_options' and return a query handle that can be used for subsequent |
| 1352 | ImpalaClient method calls for the query.""" |
| 1353 | query = self._create_query_req(query_str, set_query_options) |
| 1354 | self.is_query_cancelled = False |
| 1355 | handle, rpc_status = self._do_beeswax_rpc(lambda: self.imp_service.query(query)) |
| 1356 | if rpc_status != RpcStatus.OK: |
| 1357 | raise RPCException("Error executing the query") |
| 1358 | handle.is_closed = False |
| 1359 | return handle |
| 1360 | |
| 1361 | def get_query_id_str(self, last_query_handle): |
| 1362 | return last_query_handle.id |
nothing calls this directly
no test coverage detected