Github user yhuai commented on a diff in the pull request:
https://github.com/apache/spark/pull/9562#discussion_r44353792
--- Diff: sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala ---
@@ -749,10 +749,14 @@ class DataFrame private[sql](
// will remove intermediate Alias for ExtractValue chain, and we
need to alias it again to
// make it a NamedExpression.
case Column(u: UnresolvedAttribute) => UnresolvedAlias(u)
+
case Column(expr: NamedExpression) => expr
- // Leave an unaliased explode with an empty list of names since the
analyzer will generate the
- // correct defaults after the nested expression's type has been
resolved.
+
+ // Leave an unaliased generator with an empty list of names since
the analyzer will generate
+ // the correct defaults after the nested expression's type has been
resolved.
case Column(explode: Explode) => MultiAlias(explode, Nil)
+ case Column(jt: JsonTuple) => MultiAlias(jt, Nil)
--- End diff --
Also, what is the problem?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
