Method Push

cpp/src/arrow/acero/asof_join_node.cc:731–739

  }

  Status Push(const std::shared_ptr<arrow::RecordBatch>& rb) {
    if (rb->num_rows() > 0) {
      key_hasher_->Invalidate();  // batch changed - invalidate key hasher's cache
      queue_.Push(rb);            // only now push batch for processing
    } else {
      ++batches_processed_;  // don't enqueue empty batches, just record as processed
    }
    return Status::OK();
  }

  std::optional<const MemoStore::Entry*> GetMemoEntryForKey(ByType key) {
    return memo_.GetEntryForKey(key);