Method getOutput

bolt/exec/FilterProject.cpp:203–271

}

RowVectorPtr FilterProject::getOutput() {
  if (allInputProcessed()) {
    return nullptr;
  }

  vector_size_t size = input_->size();
  bool isCompositeInput = RowVector::isComposite(input_);

#ifdef SPARK_COMPATIBLE
  if (skipForCompositeInput_ && isCompositeInput) {
    BOLT_CHECK(!hasFilter_ && !isIdentityProjection_);
    numProcessedInputRows_ = size;
    return fillCompositeOutput(size, input_->children());
  }
#endif

  LocalSelectivityVector localRows(*operatorCtx_->execCtx(), size);
  auto* rows = localRows.get();
  BOLT_DCHECK_NOT_NULL(rows)
  rows->setAll();
  EvalCtx evalCtx(
      operatorCtx_->execCtx(),
      exprs_.get(),
      input_.get(),
      driverCtx_->currentSplitStr,
      acceptCompositeInput_);

  // Pre-load lazy vectors which are referenced by both expressions and identity
  // projections.
  for (auto fieldIdx : multiplyReferencedFieldIndices_) {
    evalCtx.ensureFieldLoaded(fieldIdx, *rows);
  }

  if (!hasFilter_) {
    numProcessedInputRows_ = size;
    BOLT_CHECK(!isIdentityProjection_);
    auto results = project(*rows, evalCtx);
    if (isCompositeInput) {
      return fillCompositeOutput(size, results);
    } else {
      return fillOutput(size, nullptr, results);
    }
  }
  BOLT_CHECK(!isCompositeInput);

  // evaluate filter
  auto numOut = filter(evalCtx, *rows);
  numProcessedInputRows_ = size;
  if (numOut == 0) { // no rows passed the filer
    input_ = nullptr;
    return nullptr;
  }

  bool allRowsSelected = (numOut == size);

  // evaluate projections (if present)
  std::vector<VectorPtr> results;
  if (!isIdentityProjection_) {