(self, query_str, set_query_options)
| 1340 | return (resp.version, resp.webserver_address) |
| 1341 | |
| 1342 | def _create_query_req(self, query_str, set_query_options): |
| 1343 | query = BeeswaxService.Query() |
| 1344 | query.hadoop_user = self.user |
| 1345 | query.query = utf8_encode_if_needed(query_str) |
| 1346 | query.configuration = self._options_to_string_list(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 |
no test coverage detected