File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -57,13 +57,14 @@ abstract class QueryPlan[PlanType <: QueryPlan[PlanType]] extends TreeNode[PlanT
5757 }
5858
5959 /**
60- * Generate IsNotNull constraints from the null intolerant child expressions of constraints.
60+ * Generate Attribute-specific IsNotNull constraints from the null intolerant child expressions
61+ * of constraints.
6162 */
6263 private def generateIsNotNullConstraints (constraint : Expression ): Seq [Expression ] =
6364 constraint match {
6465 case IsNotNull (_ : Attribute ) => constraint :: Nil
6566 // When the root is IsNotNull, we can push IsNotNull through the child null intolerant
66- // expressions.
67+ // expressions
6768 case IsNotNull (expr) => scanNullIntolerantExpr(expr).map(IsNotNull (_))
6869 // Constraints always return true for all the inputs. That means, null will never be returned.
6970 // Thus, we can infer `IsNotNull(constraint)`, and also push IsNotNull through the child
You can’t perform that action at this time.
0 commit comments