| 623 | } |
| 624 | |
| 625 | void LocalPartition::noMoreInput() { |
| 626 | Operator::noMoreInput(); |
| 627 | for (const auto& queue : queues_) { |
| 628 | queue->noMoreData(); |
| 629 | } |
| 630 | } |
| 631 | |
| 632 | bool LocalPartition::isFinished() { |
| 633 | if (!futures_.empty() || !noMoreInput_) { |
no test coverage detected