Function InitUnmaterializedTable

cpp/src/arrow/acero/asof_join_node.cc:914–928

#endif

  static CompositeTable InitUnmaterializedTable(
      const std::shared_ptr<Schema>& schema,
      const std::vector<std::unique_ptr<InputState>>& inputs, arrow::MemoryPool* pool) {
    std::unordered_map<int, std::pair<int, int>> dst_to_src;
    for (size_t i = 0; i < inputs.size(); i++) {
      auto& input = inputs[i];
      for (int src = 0; src < input->get_schema()->num_fields(); src++) {
        auto dst = input->MapSrcToDst(src);
        if (dst.has_value()) {
          dst_to_src[dst.value()] = std::make_pair(static_cast<int>(i), src);
        }
      }
    }
    return CompositeTable{schema, inputs.size(), dst_to_src, pool};
  }
};

// TODO: Currently, AsofJoinNode uses 64-bit hashing which leads to a non-negligible