@@ -201,7 +201,7 @@ private[spark] object ResolveWindowUdaf extends Rule[LogicalPlan] {
201201 sys.error(s " udaf ${wrapper.functionClassName} does not support window frame " )
202202 // if `isImpliesOrder` is true, we need to use sort expressions as parameters,
203203 // such as rank, dense_rank
204- case WindowExpression ( HiveGenericUdaf (wrapper, wfi, children), _ )
204+ case HiveGenericUdaf (wrapper, wfi, children)
205205 if (wfi.isImpliesOrder && children.isEmpty) => child match {
206206 case SortPartitions (sortExpr, _) =>
207207 HiveGenericUdaf (wrapper, wfi, children ++ sortExpr.map(_.child))
@@ -212,7 +212,7 @@ private[spark] object ResolveWindowUdaf extends Rule[LogicalPlan] {
212212 }
213213 // if function computed with window is `HiveGenericUdf`, we need to check whether
214214 // it has HiveGenericUadf one, such as lead, lag
215- case WindowExpression ( HiveGenericUdf (name, wrapper, children), _ ) =>
215+ case HiveGenericUdf (name, wrapper, children) =>
216216 val windowFunctionInfo : WindowFunctionInfo =
217217 Option (FunctionRegistry .getWindowFunctionInfo(name.toLowerCase)).getOrElse(
218218 sys.error(s " Couldn't find udaf function $name" ))
0 commit comments