Function combineInputColumns

bolt/python/Utils.cpp:188–233

}

std::shared_ptr<RowVector> combineInputColumns(
    const std::vector<VectorPtr>& args,
    const exec::EvalCtx& context) {
  std::vector<std::string> names;
  std::vector<VectorPtr> children;

  for (size_t i = 0; i < args.size(); ++i) {
    const auto& arg = args[i];
    if (arg) {
      arg->loadedVector();
      children.push_back(arg);

      std::string name;
      if (context.row()) {
        long long address = (long long)arg.get();
        for (size_t j = 0; j < context.row()->childrenSize(); ++j) {
          auto cur = context.row()->children()[j];
          if ((long long)cur.get() == address) {
            name = context.row()->type()->asRow().nameOf(j);
            break;
          }
        }
      }

      if (name.empty()) {
        name = fmt::format("col_{}", i);
      }
      names.push_back(name);
    }
  }

  if (children.empty()) {
    return RowVector::createEmpty({}, context.pool());
  }

  vector_size_t length = children[0]->size();

  std::vector<TypePtr> types;
  for (const auto& child : children) {
    types.push_back(child->type());
  }
  auto rowType = ROW(move(names), move(types));

  return std::make_shared<RowVector>(
      context.pool(), rowType, nullptr, length, children, 0);
}
} // namespace bolt::python