Method moveNext

bolt/exec/tests/utils/Cursor.cpp:325–340

Fetches another batch from the task queue. Starts the task if not started yet.

        task_->start(maxDrivers_, numConcurrentSplitGroups_);
        queue_->setNumProducers(numSplitGroups_ * task_->numOutputDrivers());
      } catch (const BoltException& e) {
        // Could not find output pipeline, due to Task terminated before
        // start. Do not override the error.
        if (e.message().find("Output pipeline not found for task") ==
            std::string::npos) {
          throw;
        }
      }
    }
  }

  /// Fetches another batch from the task queue.
  /// Starts the task if not started yet.
  bool moveNext() override {
    start();
    if (error_) {
      std::rethrow_exception(error_);
    }