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