Method applyFunctionWithPeeling

bolt/expression/Expr.cpp:1498–1543

}

bool Expr::applyFunctionWithPeeling(
    const SelectivityVector& applyRows,
    EvalCtx& context,
    VectorPtr& result) {
  LocalDecodedVector localDecoded(context);
  LocalSelectivityVector newRowsHolder(context);
  // Attempt peeling.
  std::vector<VectorPtr> peeledVectors;
  auto peeledEncoding = PeeledEncoding::peel(
      inputValues_,
      applyRows,
      localDecoded,
      vectorFunction_->isDefaultNullBehavior(),
      peeledVectors);
  if (!peeledEncoding) {
    return false;
  }
  inputValues_ = std::move(peeledVectors);
  peeledVectors.clear();

  // Translate the relevant rows.
  // Note: We do not need to translate final selection since at this stage those
  // rows are not used but isFinalSelection() is only used to check whether
  // pre-existing rows need to be preserved.
  auto newRows = peeledEncoding->translateToInnerRows(applyRows, newRowsHolder);

  withContextSaver([&](ContextSaver& saver) {
    // Save context and set the peel.
    context.saveAndReset(saver, applyRows);
    context.setPeeledEncoding(peeledEncoding);

    // Apply the function.
    VectorPtr peeledResult;
    applyFunction(*newRows, context, peeledResult);
    VectorPtr wrappedResult = context.getPeeledEncoding()->wrap(
        this->type(), context.pool(), peeledResult, applyRows);
    context.moveOrCopyResult(wrappedResult, applyRows, result);

    // Recycle peeledResult if it's not owned by the result vector. Examples of
    // when this can happen is when the result is a primitive constant vector,
    // or when moveOrCopyResult copies wrappedResult content.
    context.releaseVector(peeledResult);
  });

  return true;
}

void Expr::applyFunction(
    const SelectivityVector& rows,