spark：スクランブルRDDとそれらをジップ

Question

私は同じ長さの2つのRDDを持っていて、それらを無作為に一緒にジッパーしたいと思います（例えば最初のRDDは（A、B、C、D） Y、Z）と私は（AX、BZ、CW、DY）のようなランダムなジップをしたい。この使用pySparkを行うための高速な方法は何でしょうか。

Answer 1

何が必要このですか？

x = sc.parallelize(['A','B','C','D']) 
y = sc.parallelize(['W','X','Y','Z']) 
x = x.takeSample(False, 4) 
y = y.takeSample(False, 4) 
combine = zip(x,y) 
combine 
>> [('D', 'Z'), ('B', 'X'), ('A', 'W'), ('C', 'Y')] 

Answer 2

することができます：