は、どのように私はベクトルの集合を合計して、私はスパークのJava APIを使用していますスパーク

Question

で新しいベクトルを生成し、次のスキーマとデータをたくさん読んでください：私はデータフレームを持っていたら、私が欲しい

profits (Array of Double values): 
--------------------------------- 
[1.0,2.0,3.0] 
[2.0,3.0,4.0] 
[4,0,6.0] 

Javaのための私はスカラ座やPythonでこれを行うには、オンラインでいくつかの例を参照してください

Result: 
[7.0,11.0,7.0] 

、何も新しいすべてのベクトルの和であるベクトルを計算します。

Answer 1

val withIndex = profits.zipWithIndex // ((a,0),(b,1),(c,2)) 

は、私たちは、キーとしてインデックスを使用する必要があります。Finallly

val indexKey = withIndex.map{case (k,v) => (v,k)} //((0,a),(1,b),(2,c)) 

、

counts = indexKey.reduceByKey(lambda k, v: k + v)