| 675 | } |
| 676 | |
| 677 | Status ScanHashTable_on_finished(size_t thread_index) { |
| 678 | if (cancelled_) { |
| 679 | return Status::Cancelled("Hash join cancelled"); |
| 680 | } |
| 681 | END_SPAN(span_); |
| 682 | return finished_callback_(num_batches_produced_.load()); |
| 683 | } |
| 684 | |
| 685 | Status ScanHashTable(size_t thread_index) { |
| 686 | MergeHasMatch(); |