Method isBlocked

bolt/exec/tests/CustomJoinTest.cpp:228–245

  }

  BlockingReason isBlocked(ContinueFuture* future) override {
    if (numRows_.has_value()) {
      return BlockingReason::kNotBlocked;
    }

    auto joinBridge = operatorCtx_->task()->getCustomJoinBridge(
        operatorCtx_->driverCtx()->splitGroupId, planNodeId());
    auto numRows = std::dynamic_pointer_cast<CustomJoinBridge>(joinBridge)
                       ->numRowsOrFuture(future);

    if (!numRows.has_value()) {
      return BlockingReason::kWaitForJoinBuild;
    }
    numRows_ = std::move(numRows);
    remainingLimit_ = numRows_.value();

    return BlockingReason::kNotBlocked;
  }

  bool isFinished() override {
    return finished_ || (noMoreInput_ && input_ == nullptr);