これを行う方法が少し失われています。私はサム関数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