Class CompositeTableBuilder

cpp/src/arrow/acero/asof_join_node.cc:817–830

/// the join row-by-row
template <size_t MAX_TABLES>
class CompositeTableBuilder {
  using SliceBuilder = UnmaterializedSliceBuilder<MAX_TABLES>;
  using CompositeTable = UnmaterializedCompositeTable<MAX_TABLES>;

 public:
  NDEBUG_EXPLICIT CompositeTableBuilder(
      const std::vector<std::unique_ptr<InputState>>& inputs,
      const std::shared_ptr<Schema>& schema, arrow::MemoryPool* pool,
      DEBUG_ADD(size_t n_tables, AsofJoinNode* node))
      : unmaterialized_table(InitUnmaterializedTable(schema, inputs, pool)),
        DEBUG_ADD(n_tables_(n_tables), node_(node)) {
    DCHECK_GE(n_tables_, 1);
    DCHECK_LE(n_tables_, MAX_TABLES);
  }

  size_t n_rows() const { return unmaterialized_table.Size(); }