Method prepareForJoinProbe

bolt/exec/HashTable.cpp:2351–2383

}

void BaseHashTable::prepareForJoinProbe(
    HashLookup& lookup,
    const RowVectorPtr& input,
    SelectivityVector& rows,
    bool decodeAndRemoveNulls) {
  auto& hashers = lookup.hashers;

  if (decodeAndRemoveNulls) {
    for (auto& hasher : hashers) {
      auto key = input->childAt(hasher->channel())->loadedVector();
      hasher->decode(*key, rows);
    }

    // A null in any of the keys disables the row.
    deselectRowsWithNulls(hashers, rows);
  }

  lookup.reset(rows.end());

  const auto mode = hashMode();
  for (auto i = 0; i < hashers.size(); ++i) {
    auto& hasher = hashers[i];
    if (mode != BaseHashTable::HashMode::kHash) {
      auto& key = input->childAt(hasher->channel());
      hashers_[i]->lookupValueIds(
          *key, rows, lookup.scratchMemory, lookup.hashes);
    } else {
      hasher->hash(rows, i > 0, lookup.hashes);
    }
  }

  populateLookupRows(rows, lookup.rows);
}

} // namespace bytedance::bolt::exec