| 1410 | } |
| 1411 | |
| 1412 | void HashBuild::postHashBuildProcess() { |
| 1413 | checkRunning(); |
| 1414 | |
| 1415 | if (!spillEnabled()) { |
| 1416 | setState(State::kFinish); |
| 1417 | return; |
| 1418 | } |
| 1419 | |
| 1420 | auto spillInput = joinBridge_->spillInputOrFuture(&future_); |
| 1421 | if (!spillInput.has_value()) { |
| 1422 | BOLT_CHECK(future_.valid()); |
| 1423 | setState(State::kWaitForProbe); |
| 1424 | return; |
| 1425 | } |
| 1426 | setupSpillInput(std::move(spillInput.value())); |
| 1427 | } |
| 1428 | |
| 1429 | void HashBuild::setupSpillInput(HashJoinBridge::SpillInput spillInput) { |
| 1430 | checkRunning(); |
nothing calls this directly
no test coverage detected