From 5ee5d2c52d34fec40660f00a0135b72d0e5e581c Mon Sep 17 00:00:00 2001 From: Cheng Hao Date: Sat, 18 Apr 2015 01:24:36 +0800 Subject: [PATCH] prepend the new qualifier --- .../spark/sql/catalyst/plans/logical/basicOperators.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala index ca0a700869a0e..4e8436cd7535a 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala @@ -72,7 +72,8 @@ case class Generate( val withoutQualifier = if (join) child.output ++ generatorOutput else generatorOutput qualifier.map(q => - withoutQualifier.map(_.withQualifiers(q :: Nil)) + // prepend the new qualifier to the existed one + withoutQualifier.map(a => a.withQualifiers(q +: a.qualifiers)) ).getOrElse(withoutQualifier) } }