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

Method ForceShutdown

cpp/src/arrow/acero/asof_join_node.cc:766–770  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

764 }
765
766 void ForceShutdown() {
767 // Force the upstream input node to unpause. Necessary to avoid deadlock when we
768 // terminate the process thread
769 queue_.ForceShutdown();
770 }
771
772 private:
773 // ExecBatch Sequencer

Callers 3

EndFromProcessThreadMethod · 0.45
EndFromSingleThreadMethod · 0.45
TESTFunction · 0.45

Calls

no outgoing calls

Tested by 1

TESTFunction · 0.36