Ich schreibe eine Spark-Anwendung und möchte eine Reihe von Schlüssel-Wert-Paaren kombinieren(K, V1), (K, V2), ..., (K, Vn) in ein Schlüssel-Mehrwert-Paar(K, [V1, V2, ..., Vn]). Ich habe das Gefühl, ich sollte dies mit dem @ tun könnreduceByKey Funktion mit etwas vom Geschmack:

My_KMV = My_KV.reduce(lambda a, b: a.append([b]))

Der Fehler, den ich bekomme, wenn dies auftritt, ist:

'NoneType' Objekt hat kein Attribut 'Anhängen'.

Meine Schlüssel sind ganze Zahlen und die Werte V1, ..., Vn sind Tupel. Mein Ziel ist es, ein einzelnes Paar mit dem Schlüssel und einer Liste der Werte (Tupel) zu erstellen.