我有点迷失在如何做到这一点。我正在实现总和函数MADlib。这个函数数组任意数量并补充说:sum MADlib UDF Spark SQL
sum (array [ 1,2] , array [2,3 ] , array [4,5 ])
Return : [7,10]
我要创建的下一条语句返回相同结果的函数,而不是如何实现这样的事情:
def sum[T](args: WrappedArray[T]*)(implicit n: Numeric[T]) = {
var i : Int = 0;
for(arg <- args){
// Code
i = i + 1;
}
}
sqlContext.udf.register("sum", sum(_:WrappedArray[Int]*))
sqlContext.sql("SELECT sum(collect_list(a),collect_list(b),collect_list(c)) from df").show
这个问题解决了吗? – slouc