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

Method PushProcess

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

Source from the content-addressed store, hash-verified

1452 return Status::OK();
1453 }
1454 void PushProcess(bool value) {
1455#ifdef ARROW_ENABLE_THREADING
1456 process_.Push(value);
1457#else
1458 if (value) {
1459 ProcessNonThreaded();
1460 } else if (!process_task_.is_finished()) {
1461 EndFromSingleThread();
1462 }
1463#endif
1464 }
1465
1466#ifndef ARROW_ENABLE_THREADING
1467 bool ProcessNonThreaded() {

Callers

nothing calls this directly

Calls 2

PushMethod · 0.45
is_finishedMethod · 0.45

Tested by

no test coverage detected