| 132 | slowJoinBuildDelaySeconds_(joinNode->slowJoinBuildDelaySeconds()) {} |
| 133 | |
| 134 | void addInput(RowVectorPtr /* input */) override { |
| 135 | // Make driver with id 0 slower than other drivers |
| 136 | auto driverId = operatorCtx_->driverCtx()->driverId; |
| 137 | if (driverId == 0) { |
| 138 | std::this_thread::sleep_for( |
| 139 | std::chrono::seconds(slowJoinBuildDelaySeconds_)); |
| 140 | } |
| 141 | } |
| 142 | |
| 143 | bool needsInput() const override { |
| 144 | return !noMoreInput_; |