Method ExpandNode

bolt/core/PlanNode.cpp:532–565

  return ROW(std::move(names), std::move(types));
}
} // namespace

ExpandNode::ExpandNode(
    PlanNodeId id,
    std::vector<std::vector<TypedExprPtr>> projections,
    std::vector<std::string> names,
    PlanNodePtr source)
    : PlanNode(std::move(id)),
      sources_{source},
      outputType_(getExpandOutputType(projections, std::move(names))),
      projections_(std::move(projections)) {
  const auto& projectionNames = outputType_->names();
  const auto numColumns = projectionNames.size();
  const auto numRows = projections_.size();

  for (const auto& rowProjection : projections_) {
    for (const auto& columnProjection : rowProjection) {
      BOLT_USER_CHECK(
          TypedExprs::isFieldAccess(columnProjection) ||
              TypedExprs::isConstant(columnProjection),
          "Unsupported projection expression in Expand plan node. Expected field reference or constant. Got: {} ",
          columnProjection->toString());
    }
  }

  for (int i = 0; i < numColumns; ++i) {
    const auto& type = outputType_->childAt(i);
    for (int j = 1; j < numRows; ++j) {
      BOLT_USER_CHECK(
          projections_[j][i]->type()->equivalent(*type),
          "The projections type does not match across different rows in the same column. Got: {}, {}",
          projections_[j][i]->type()->toString(),
          type->toString());
    }
  }
}