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

Method noMoreInput

bolt/exec/NestedLoopJoinProbe.cpp:204–214  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

202}
203
204void NestedLoopJoinProbe::noMoreInput() {
205 Operator::noMoreInput();
206 if (state_ != ProbeOperatorState::kRunning || input_ != nullptr) {
207 return;
208 }
209 if (!needsBuildMismatch(joinType_) || isBuildSideEmpty()) {
210 setState(ProbeOperatorState::kFinish);
211 return;
212 }
213 beginBuildMismatch();
214}
215
216bool NestedLoopJoinProbe::getBuildData(ContinueFuture* future) {
217 BOLT_CHECK(!buildVectors_.has_value());

Callers

nothing calls this directly

Calls 1

needsBuildMismatchFunction · 0.85

Tested by

no test coverage detected