PySpark reduceByKeyが

Question

だから私はこの質問と同じタイトル持ちながら：PySpark reduceByKey on multiple values

私は答えは私がやりたいことのために動作させることはできませんが。

A = sc.parallelize([("a", (1,0)), ("b", (4,2)),("a", (11,2)), ("b", (4,10))]) 
A.reduceByKey(lambda x, y: x[0]+y[0],x[1]+y[1]).collect() 

は私にエラーを与える：ここで起こっていただきました

name 'x' is not defined 

？

Answer 1

問題が見つかりました。一部のかっこ：

A.reduceByKey(lambda x, y: (x[0]+y[0] ,x[1]+y[1])).collect()