xinrong-meng commented on code in PR #47884: URL: https://github.com/apache/spark/pull/47884#discussion_r1737609015
########## sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicLogicalOperators.scala: ########## @@ -1474,6 +1474,31 @@ case class Pivot( override protected def withNewChildInternal(newChild: LogicalPlan): Pivot = copy(child = newChild) } +/** + * A constructor for creating a transpose, which will later be converted + * to a [[LocalRelation]] during the query optimization. + * + * The result of the transpose operation is held in the `data` field, and the corresponding + * schema is stored in the `output` field. The `Transpose` node does not depend on any child + * logical plans after the data has been collected and transposed. + * + * @param output A sequence of output attributes representing the schema of the transposed data. + * @param data A sequence of [[InternalRow]] containing the transposed data. + */ +case class Transpose( + output: Seq[Attribute], + data: Seq[InternalRow] = Nil, + hasNonIndexColumns: Boolean = true Review Comment: Good catch added -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
