| 214 | } |
| 215 | |
| 216 | bool NestedLoopJoinProbe::getBuildData(ContinueFuture* future) { |
| 217 | BOLT_CHECK(!buildVectors_.has_value()); |
| 218 | |
| 219 | auto buildData = |
| 220 | operatorCtx_->task() |
| 221 | ->getNestedLoopJoinBridge( |
| 222 | operatorCtx_->driverCtx()->splitGroupId, planNodeId()) |
| 223 | ->dataOrFuture(future); |
| 224 | if (!buildData.has_value()) { |
| 225 | return false; |
| 226 | } |
| 227 | |
| 228 | buildVectors_ = std::move(buildData); |
| 229 | return true; |
| 230 | } |
| 231 | |
| 232 | RowVectorPtr NestedLoopJoinProbe::getOutput() { |
| 233 | if (state_ == ProbeOperatorState::kFinish || |
nothing calls this directly
no test coverage detected