Schlüssel in reduceByKey() erhalten api funke

Question

Gibt es eine Möglichkeit, wie ich den Namen des Schlüssels in pyspark innerhalb der Funktion reduceByKey() bekommen kann, so dass ich bekommen kann, welcher Schlüssel ist üblich zwischen den beiden Werten in die reduceByKey() funktionieren?

Zum Beispiel:

inside reduceByKey(combineValues) where 

def combineValues(a,b): 
//can i get the key value common to both a and b here ?? 
return a+b; 

Answer 1

können Sie verwenden, um die aggregate Funktion auf RDD, aber verlieren Sie den HashPartitioner Nutzen, so würde ich vorschlagen, den Schlüssel in Ihren Werten zu speichern, wenn es wichtig ist.