Method execute_async

tests/common/impala_connection.py:462–466

(self, sql_stmt, user=None)

        fetch_exec_summary=fetch_exec_summary)

  def execute_async(self, sql_stmt, user=None):
    self.log_client(u"executing async {0}\n{1}".format(
      self.__host_port, format_sql_for_logging(sql_stmt)))
    beeswax_handle = self.__beeswax_client.execute_query_async(sql_stmt, user=user)
    return OperationHandle(beeswax_handle, sql_stmt)

  def cancel(self, operation_handle):
    self.log_handle(operation_handle, 'canceling operation')