Method GetNext

be/src/exec/hdfs-scanner.h:135–143

Returns the next row batch from this scanner's split. Recoverable errors are logged to the runtime state. Only returns a non-OK status if a non-recoverable error is encountered (or abort_on_error is true). If OK is returned, 'parse_status_' is guaranteed to be OK as well. The memory referenced by the tuples is valid until this or any subsequently returned batch is reset or destroyed. Only valid to

  /// returned batch is reset or destroyed.
  /// Only valid to call if the parent scan node is single-threaded.
  Status GetNext(RowBatch* row_batch) WARN_UNUSED_RESULT {
    DCHECK(!scan_node_->HasRowBatchQueue());
    RETURN_IF_ERROR(GetNextInternal(row_batch));
    ++getnext_batches_returned_;
    if ((getnext_batches_returned_ & (BATCHES_PER_FILTER_SELECTIVITY_CHECK - 1)) == 0) {
      CheckFiltersEffectiveness();
    }
    return Status::OK();
  }

  /// Process an entire split, reading bytes from the context's streams.  Context is
  /// initialized with the split data (e.g. template tuple, partition descriptor, etc).