Skip to content

Commit 04ae500

Browse files
add qualifier only for generator output
1 parent 5ee5d2c commit 04ae500

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -69,12 +69,12 @@ case class Generate(
6969
override def expressions: Seq[Expression] = generator :: Nil
7070

7171
def output: Seq[Attribute] = {
72-
val withoutQualifier = if (join) child.output ++ generatorOutput else generatorOutput
73-
74-
qualifier.map(q =>
72+
val qualified = qualifier.map(q =>
7573
// prepend the new qualifier to the existed one
76-
withoutQualifier.map(a => a.withQualifiers(q +: a.qualifiers))
77-
).getOrElse(withoutQualifier)
74+
generatorOutput.map(a => a.withQualifiers(q +: a.qualifiers))
75+
).getOrElse(generatorOutput)
76+
77+
if (join) child.output ++ qualified else qualified
7878
}
7979
}
8080

0 commit comments

Comments
 (0)