Method fetch

tests/common/impala_connection.py:284–291

Fetches query results up to max_rows given a handle and sql statement. Caller must ensure that query has passed PENDING state before calling fetch. If max_rows < 0, all rows are fetched. If max_rows > 0 but the number of rows returned is less than max_rows, all the rows have been fetched

(self, sql_stmt, operation_handle, max_rows=-1, discard_results=False)

  @abc.abstractmethod
  def fetch(self, sql_stmt, operation_handle, max_rows=-1, discard_results=False):
    """Fetches query results up to max_rows given a handle and sql statement.
    Caller must ensure that query has passed PENDING state before calling fetch.
    If max_rows < 0, all rows are fetched. If max_rows > 0 but the number of
    rows returned is less than max_rows, all the rows have been fetched.
    Return None if discard_results is True.
    TODO: 'sql_stmt' can be obtained from 'operation_handle'."""
    pass

  @abc.abstractmethod
  def get_runtime_profile(self, operation_handle,