Method InputReceived

cpp/src/arrow/acero/sink_node.cc:224–236

  }

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

    DCHECK_EQ(input, inputs_[0]);

    RecordBackpressureBytesUsed(batch);
    if (sequencer_) {
      ARROW_RETURN_NOT_OK(sequencer_->InsertBatch(std::move(batch)));
    } else {
      ARROW_RETURN_NOT_OK(Process(std::move(batch)));
    }
    return Status::OK();
  }

  Status Process(ExecBatch batch) override {
    producer_.Push(std::move(batch));