Wie invertiere ich Schlüssel und Wert in RDD in Python 3 pyspark?

Question

Dies funktioniert in Python 2.7, aber in Python 3.5 kehrt

SyntaxError: invalid syntax.

Ich bin nicht sicher, ob dies mit der Tatsache zu tun hat, dass „Tupel Auspacken“ von Python 3 entfernt wurde, als ich auf einem anderen lesen Post, oder ist ein anderes Problem.

rddInverted = rdd.map(lambda (x,y): (y,x)) 

Answer 1

so etwas wie dieses Versuchen:

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

Ich hoffe, dass es

arbeiten

Answer 2

Ihre Lambda-Funktion auf der Zeile des RDD ist, die ein Tupel. Unten ist was du willst.

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

Answer 3

Die Lösung lautet:

rddInverted=rdd.map(lambda xy: (xy[1],xy[0]))