We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent eee74e7 commit dd9daceCopy full SHA for dd9dace
1 file changed
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/QueryPlan.scala
@@ -443,7 +443,10 @@ object QueryPlan extends PredicateHelper {
443
}.canonicalized.asInstanceOf[T]
444
}
445
446
- /** Normalize and reorder the expressions in the given sequence. */
+ /**
447
+ * Composes the given predicates into a conjunctive predicate, which is normalized and reordered.
448
+ * Then returns a new sequence of predicates by splitting the conjunctive predicate.
449
+ */
450
def normalizePredicates(predicates: Seq[Expression], output: AttributeSeq): Seq[Expression] = {
451
if (predicates.nonEmpty) {
452
val normalized = normalizeExprId(predicates.reduce(And), output)
0 commit comments