| 1512 | #endif |
| 1513 | |
| 1514 | Status StartProducing() override { |
| 1515 | ARROW_ASSIGN_OR_RAISE(process_task_, plan_->query_context()->BeginExternalTask( |
| 1516 | "AsofJoinNode::ProcessThread")); |
| 1517 | if (!process_task_.is_valid()) { |
| 1518 | // Plan has already aborted. Do not start process thread |
| 1519 | return Status::OK(); |
| 1520 | } |
| 1521 | #ifdef ARROW_ENABLE_THREADING |
| 1522 | process_thread_ = std::thread(&AsofJoinNode::ProcessThreadWrapper, this); |
| 1523 | #endif |
| 1524 | return Status::OK(); |
| 1525 | } |
| 1526 | |
| 1527 | void PauseProducing(ExecNode* output, int32_t counter) override {} |
| 1528 | void ResumeProducing(ExecNode* output, int32_t counter) override {} |
nothing calls this directly
no test coverage detected