parameters: (self, query_str, set_query_options)
return_statement: return handle
docstring: 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.
docstring_summary: 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.
docstring_tokens: 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 .
function: def execute_query(self, query_str, set_query_options):
      """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."""
      query = self._create_query_req(query_str, set_query_options)
      self.is_query_cancelled = False
      handle, rpc_status = self._do_beeswax_rpc(lambda: self.imp_service.query(query))
      if rpc_status != RpcStatus.OK:
        raise RPCException("Error executing the query")
      handle.is_closed = False
      return handle
function_tokens: def execute_query ( self , query_str , set_query_options ) : query = self . _create_query_req ( query_str , set_query_options ) self . is_query_cancelled = False handle , rpc_status = self . _do_beeswax_rpc ( lambda : self . imp_service . query ( query ) ) if rpc_status != RpcStatus . OK : raise RPCException ( "Error executing the query" ) handle . is_closed = False return handle