Pass BFs to TupleBPS for further steps

Author: AestheticAkhmad

dbcon/joblist/primitivestep.h

@@ -1472,6 +1472,13 @@ class TupleBPS : public BatchPrimitive, public TupleDeliveryStep
   bool compareRange(uint8_t COP, int64_t min, int64_t max, int64_t val) const;
   bool hasPCFilter, hasPMFilter, hasRIDFilter, hasSegmentFilter, hasDBRootFilter, hasSegmentDirFilter,
       hasPartitionFilter, hasMaxFilter, hasMinFilter, hasLBIDFilter, hasExtentIDFilter;
+
+  // Blocked Bloom filter
+  std::vector<std::shared_ptr<std::array<std::optional<BlockedBloomFilter>, 2>>> bloomFilters;
+
+  public:
+  void setBloomFilters(std::vector<std::shared_ptr<std::array<std::optional<BlockedBloomFilter>, 2>>>&& bloomFilters);
+
 };
 
 /** @brief class FilterStep

dbcon/joblist/tuple-bps.cpp

@@ -3394,6 +3394,11 @@ void TupleBPS::abort()
   abort_nolock();
 }
 
+void TupleBPS::setBloomFilters(std::vector<std::shared_ptr<std::array<std::optional<BlockedBloomFilter>, 2>>>&& bloomFilters)
+{
+  this->bloomFilters = std::move(bloomFilters);
+}
+
 template bool TupleBPS::processOneFilterType<int64_t>(int8_t colWidth, int64_t value, uint32_t type) const;
 template bool TupleBPS::processOneFilterType<int128_t>(int8_t colWidth, int128_t value, uint32_t type) const;
 

dbcon/joblist/tuplehashjoin.cpp

@@ -688,6 +688,8 @@ void TupleHashJoinStep::hjRunner()
   jobstepThreadPool.join(smallRunners);
   smallRunners.clear();
 
+  largeBPS->setBloomFilters(std::move(bloomFilters));
+
   for (i = 0; i < feIndexes.size() && joiners.size() > 0; i++)
     joiners[feIndexes[i]]->setFcnExpFilter(fe[i]);