Wie finde ich die Schlüssel-Wert-Paare, die im Spark-Streaming den geringsten Wert haben?

Question

Ich muss den kleinsten Wert finden und seinen Schlüssel in Stream zurückgeben. Aber ich habe keine Ahnung, wie es geht, ich suchte API-Dokumente, aber finde nichts, würde mir jemand gerne beibringen, wie man es macht?

Answer 1

Versuchen:

>>> stream = ssc.queueStream([sc.parallelize([("a", 1), ("b", 2)])]) 
>>> stream.map(lambda x: (x[1], x[0])).reduce(min).map(lambda x: x[1]).pprint()