スパークパイソンSIGLEタプルにネストされたタプルでRDDタプルを変換

Question

私は私の最後のRDDを持っていると同じように見えます：

(44, 136.38, 2) 
(2, 108.53, 3) 
(4, 24.13, 1) 
(35, 65.89, 1) 

ご注意：私は形でそれを持ってしたいと思います

(44, (136.38, 2)) 
(2, (108.53, 3)) 
(4, (24.13, 1)) 
(35, (65.89, 1)) 

これは他の二つのRDDSから作成スパークRDD、あること：

combined = reduced_total.join(reduced_count) 

私は仕事を達成できます。

combined = combined.map(lambda x: (x[0],x[1][0],x[1][1])) 

しかし、非常にピジョンソニックなようです。どんなより良い提案ですか？

Answer 1

あなたは解凍することができます：

combined.map(lambda x: (x[0], *x[1])) # Python 3 

または連結を：

# this creates a single element tuple and uses __add__ method on it. 
combined.map(lambda x: (x[0],) + x[1])