| 784 | const char* kind_name() const override { return "HashJoinNode"; } |
| 785 | |
| 786 | Status OnBuildSideBatch(size_t thread_index, ExecBatch batch) { |
| 787 | if (batch.length == 0) { |
| 788 | return Status::OK(); |
| 789 | } |
| 790 | std::lock_guard<std::mutex> guard(build_side_mutex_); |
| 791 | build_accumulator_.InsertBatch(std::move(batch)); |
| 792 | return Status::OK(); |
| 793 | } |
| 794 | |
| 795 | Status OnBuildSideFinished(size_t thread_index) { |
| 796 | return pushdown_context_.BuildBloomFilter( |
nothing calls this directly
no test coverage detected