2016-10-18 10 views
0

ペアのRDDを仮定すると、同じキーセットと(各キーの)デカルト積を新しい値として別のRDDを生成するにはどうすればよいですか?ここで各キーの値のデカルト積

は私が何を意味するかです:

//Given 
(K1, V1) 
(K1, V2) 
(K2, W1) 
(K2, W2) 

//Want 
(K1, (V1, V1)) 
(K1, (V1, V2)) 
(K1, (V2, V2)) 
(K2, (W1, W1)) 
(K2, (W1, W2)) 
(K2, (W2, W2)) 
//Note (V2, V1) and (W2, W1) are not required, but having them in the result is not a big deal either. 

はスカラとスパークに新たなので、私はビルドになmapValuesような変換使って、簡単な解決策は表示されません。私はいくつかの魔法の機能を欠いていますか?どうもありがとう。

答えて

3

ただ自分自身との事への参加:

rdd.join(rdd) 
+1

私は答えはこの単純なことを期待していませんでした。完璧に働いた。ありがとう! –

関連する問題