Method InputReceived

cpp/src/arrow/acero/sink_node.cc:377–386

  }

  Status InputReceived(ExecNode* input, ExecBatch batch) override {
    auto scope = TraceInputReceived(batch);

    DCHECK_EQ(input, inputs_[0]);

    if (sequencer_) {
      return sequencer_->InsertBatch(std::move(batch));
    }
    return Process(std::move(batch));
  }

  Status Process(ExecBatch batch) override {
    // This can happen if an error was received and the source hasn't yet stopped.  Since