MCPcopy Create free account
hub / github.com/apache/arrow / ScanHashTable_on_finished

Method ScanHashTable_on_finished

cpp/src/arrow/acero/hash_join.cc:677–683  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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();

Callers

nothing calls this directly

Calls 2

CancelledFunction · 0.85
loadMethod · 0.45

Tested by

no test coverage detected