Method fetch

tests/common/impala_connection.py:849–852

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

    return '\n'.join(lines)

  def fetch(self, sql_stmt, operation_handle, max_rows=-1, discard_results=False):
    self.log_handle(operation_handle, 'fetching {} rows'.format(
      'all' if max_rows < 0 else max_rows))
    return self.__fetch_results(operation_handle, max_rows, discard_results)

  def __fetch_results(self, handle, max_rows=-1,
                      discard_results=False,