Run 'query' with given test 'vector'. 'vector' must have 'protocol' and 'exec_option' dimension. Default ImpalaTestSuite client will be used depending on value of 'protocol' dimension.
(self, query, vector)
| 1311 | return client.close_query(query) |
| 1312 | |
| 1313 | def execute_query_using_vector(self, query, vector): |
| 1314 | """Run 'query' with given test 'vector'. |
| 1315 | 'vector' must have 'protocol' and 'exec_option' dimension. |
| 1316 | Default ImpalaTestSuite client will be used depending on value of 'protocol' |
| 1317 | dimension.""" |
| 1318 | client = self.default_impala_client(vector.get_protocol()) |
| 1319 | result = self.execute_query_using_client(client, query, vector) |
| 1320 | # Restore client configuration before returning. |
| 1321 | modified_configs = vector.get_exec_option_dict().keys() |
| 1322 | for name in modified_configs: |
| 1323 | client.set_configuration_option(name, "") |
| 1324 | return result |
| 1325 | |
| 1326 | @execute_wrapper |
| 1327 | def execute_query_async(self, query, query_options=None): |
no test coverage detected