Method fillFilterInput

bolt/exec/HashProbe.cpp:1272–1310

}

RowVectorPtr HashProbe::fillFilterInput(vector_size_t size) {
  std::vector<VectorPtr> filterColumns(filterInputType_->size());
  for (auto projection : filterInputProjections_) {
    if (std::any_of(
            projectedInputColumns_.begin(),
            projectedInputColumns_.end(),
            [&](const auto& p) {
              return p.inputChannel == projection.inputChannel;
            })) {
      // If the column is projected to the output, ensure it's loaded if it's
      // lazy in case the filter only loads an incomplete subset of the rows
      // that will be output.
      ensureLoaded(projection.inputChannel);
    } else {
      // If the column isn't projected to the output, the Vector will only be
      // reused if we've broken the input batch into multiple output batches,
      // i.e. if results_ is not at the end of the iterator.
      ensureLoadedIfNotAtEnd(projection.inputChannel);
    }
  }

  wrapIndirectChildren(
      filterInputProjections_,
      input_->children(),
      size,
      outputRowMapping_,
      filterColumns);

  extractColumns(
      table_.get(),
      folly::Range<char**>(outputTableRows_.data(), size),
      filterTableProjections_,
      pool(),
      filterInputType_->children(),
      filterColumns);

  return std::make_shared<RowVector>(
      pool(), filterInputType_, nullptr, size, std::move(filterColumns));
}

void HashProbe::prepareFilterRowsForNullAwareJoin(
    const RowVector* filterInput,