(self, last_query_handle)
| 893 | return rows |
| 894 | |
| 895 | def close_dml(self, last_query_handle): |
| 896 | try: |
| 897 | self._set_current_query_handle(last_query_handle) |
| 898 | |
| 899 | def CloseImpalaOperation(req): |
| 900 | return self.imp_service.CloseImpalaOperation(req) |
| 901 | # CloseImpalaOperation rpc is not idempotent for dmls. |
| 902 | req = TCloseImpalaOperationReq(last_query_handle) |
| 903 | resp = self._do_hs2_rpc(CloseImpalaOperation, req) |
| 904 | self._check_hs2_rpc_status(resp.status) |
| 905 | if not resp.dml_result: |
| 906 | raise RPCException("Impala DML operation did not return DML statistics.") |
| 907 | last_query_handle.is_closed = True |
| 908 | return self._process_dml_result(resp.dml_result) |
| 909 | finally: |
| 910 | self._clear_current_query_handle() |
| 911 | |
| 912 | def close_query(self, last_query_handle): |
| 913 | try: |
nothing calls this directly
no test coverage detected