Method Process

cpp/src/arrow/acero/asof_join_node.cc:707–712

  }

  Status Process(ExecBatch batch) override {
    auto rb = *batch.ToRecordBatch(schema_);
    DEBUG_SYNC(node_, "received batch from input ", index_, ":", DEBUG_MANIP(std::endl),
               rb->ToString(), DEBUG_MANIP(std::endl));
    return Push(rb);
  }
  void Rehash() {
    DEBUG_SYNC(node_, "rehashing for input ", index_, ":", DEBUG_MANIP(std::endl));
    MemoStore new_memo(DEBUG_ADD(memo_.no_future_, node_, index_));