| 954 | } |
| 955 | |
| 956 | void Driver::closeOperators() { |
| 957 | // Close operators. |
| 958 | for (auto& op : operators_) { |
| 959 | op->close(); |
| 960 | } |
| 961 | |
| 962 | // Add operator stats to the task. |
| 963 | for (auto& op : operators_) { |
| 964 | auto stats = op->stats(true); |
| 965 | stats.numDrivers = 1; |
| 966 | task()->addOperatorStats(stats); |
| 967 | } |
| 968 | } |
| 969 | |
| 970 | void Driver::close() { |
| 971 | if (closed_) { |
nothing calls this directly
no test coverage detected