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()