Liste der Listen in pySpark RDD zusammenfügen

Question

Ich habe Listen von Tupeln, die ich zu einer Liste kombinieren möchte. Ich war in der Lage, die Daten zu verarbeiten, indem ich lambdas verwendete und das Verständnis auflistete, wo ich nahe daran bin, reduceByKey zu benutzen, aber nicht sicher, wie man die Listen mergt. Also das Format ...

[[(0, 14), (0, 24)], [(1, 19), (1, 50)], ...] 

Und ich möchte es so sein ....

[(0, 14), (0, 24), (1, 19), (1, 50), ...] 

Code, der mich da, wo ich sein muss ...

test = test.map(lambda x: (x[1], [e * local[x[1]] for e in x[0]])) 
test = test.map(lambda x: [(x[0], y) for y in x[1]]) 

Aber nicht sicher, von dort aus, was für die Bereitstellung des Hinweises der Listen

Answer 1

Sie tun können,

test = test.flatMap(identity) 

oder

test = test.flatMap(lambda list: list) 

Answer 2

Dank @mrsrinivas zu verschmelzen zu tun ...

test = test.flatMap (Lambda xs: [(x [0], x [1]) für x in xs])