Skip to content

Commit 9ca1990

Browse files
committed
bring back filter logic and and an or condition
1 parent 4af96a1 commit 9ca1990

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/FunctionRegistry.scala

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -581,6 +581,9 @@ object FunctionRegistry {
581581
val params = Seq.fill(expressions.size)(classOf[Expression])
582582
val f = constructors.find(_.getParameterTypes.toSeq == params).getOrElse {
583583
val validParametersCount = constructors
584+
.filter(_.getParameterTypes.forall { t =>
585+
t == classOf[Expression] || t == classOf[Seq[Expression]]
586+
})
584587
.map(_.getParameterCount).distinct.sorted
585588
val expectedNumberOfParameters = if (validParametersCount.length == 1) {
586589
validParametersCount.head.toString

0 commit comments

Comments
 (0)