MCPcopy Create free account
hub / github.com/bytedance/bolt / getBuildData

Method getBuildData

bolt/exec/NestedLoopJoinProbe.cpp:216–230  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

214}
215
216bool 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
232RowVectorPtr NestedLoopJoinProbe::getOutput() {
233 if (state_ == ProbeOperatorState::kFinish ||

Callers

nothing calls this directly

Calls 5

has_valueMethod · 0.80
dataOrFutureMethod · 0.80
taskMethod · 0.80
driverCtxMethod · 0.45

Tested by

no test coverage detected