Method needsInput

bolt/exec/HashProbe.h:51–64

  void initialize() override;

  bool needsInput() const override {
    if (state_ == ProbeOperatorState::kFinish || noMoreInput_ ||
        noMoreSpillInput_ || input_ != nullptr) {
      return false;
    }
    if (table_) {
      return true;
    }
    // NOTE: if we can't apply dynamic filtering, then we can start early to
    // read input even before the hash table has been built.
    auto channels = operatorCtx_->driverCtx()->driver->canPushdownFilters(
        this, keyChannels_);
    return channels.empty();
  }

  void addInput(RowVectorPtr input) override;