aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorHerman van Hovell <hvanhovell@databricks.com>2016-12-06 05:51:39 -0800
committerHerman van Hovell <hvanhovell@databricks.com>2016-12-06 05:51:39 -0800
commit381ef4ea76b0920e05c81adb44b1fef88bee5d25 (patch)
tree394bac7bebd57d36317a516ffb2756fd51de5cc3
parent7863c623791d088684107f833fdecb4b5fdab4ec (diff)
downloadspark-381ef4ea76b0920e05c81adb44b1fef88bee5d25.tar.gz
spark-381ef4ea76b0920e05c81adb44b1fef88bee5d25.tar.bz2
spark-381ef4ea76b0920e05c81adb44b1fef88bee5d25.zip
[SPARK-18634][SQL][TRIVIAL] Touch-up Generate
## What changes were proposed in this pull request? I jumped the gun on merging https://github.com/apache/spark/pull/16120, and missed a tiny potential problem. This PR fixes that by changing a val into a def; this should prevent potential serialization/initialization weirdness from happening. ## How was this patch tested? Existing tests. Author: Herman van Hovell <hvanhovell@databricks.com> Closes #16170 from hvanhovell/SPARK-18634.
-rw-r--r--sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicLogicalOperators.scala2
1 files changed, 1 insertions, 1 deletions
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicLogicalOperators.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicLogicalOperators.scala
index 324662e5bd..c210b74e8a 100644
--- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicLogicalOperators.scala
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicLogicalOperators.scala
@@ -93,7 +93,7 @@ case class Generate(
override def producedAttributes: AttributeSet = AttributeSet(generatorOutput)
- val qualifiedGeneratorOutput: Seq[Attribute] = qualifier.map { q =>
+ def qualifiedGeneratorOutput: Seq[Attribute] = qualifier.map { q =>
// prepend the new qualifier to the existed one
generatorOutput.map(a => a.withQualifier(Some(q)))
}.getOrElse(generatorOutput)