diff options
author | Herman van Hovell <hvanhovell@databricks.com> | 2016-12-06 05:51:39 -0800 |
---|---|---|
committer | Herman van Hovell <hvanhovell@databricks.com> | 2016-12-06 05:51:39 -0800 |
commit | 381ef4ea76b0920e05c81adb44b1fef88bee5d25 (patch) | |
tree | 394bac7bebd57d36317a516ffb2756fd51de5cc3 | |
parent | 7863c623791d088684107f833fdecb4b5fdab4ec (diff) | |
download | spark-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.scala | 2 |
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) |