File tree Expand file tree Collapse file tree 1 file changed +5
-4
lines changed
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical Expand file tree Collapse file tree 1 file changed +5
-4
lines changed Original file line number Diff line number Diff line change @@ -111,8 +111,10 @@ case class Generate(
111111
112112 val unrequiredSet : Set [Int ] = unrequiredChildIndex.toSet
113113
114- lazy val requiredChildOutput : Seq [Attribute ] =
114+ lazy val requiredChildOutput : Seq [Attribute ] = {
115+ val unrequiredSet = unrequiredChildIndex.toSet
115116 child.output.zipWithIndex.filterNot(t => unrequiredSet.contains(t._2)).map(_._1)
117+ }
116118
117119 override lazy val resolved : Boolean = {
118120 generator.resolved &&
@@ -136,8 +138,7 @@ case class Generate(
136138 }
137139
138140 def output : Seq [Attribute ] = requiredChildOutput ++ qualifiedGeneratorOutput
139- override def metadataOutput : Seq [Attribute ] =
140- child.metadataOutput.zipWithIndex.filterNot(t => unrequiredSet.contains(t._2)).map(_._1)
141+ override def metadataOutput : Seq [Attribute ] = child.metadataOutput
141142}
142143
143144case class Filter (condition : Expression , child : LogicalPlan )
@@ -376,7 +377,7 @@ case class Join(
376377
377378 override def metadataOutput : Seq [Attribute ] = {
378379 joinType match {
379- case j : ExistenceJoin =>
380+ case ExistenceJoin (_) =>
380381 left.metadataOutput
381382 case LeftExistence (_) =>
382383 left.metadataOutput
You can’t perform that action at this time.
0 commit comments