如何找到Spark-streaming中具有最小值的键值对？

Question

我需要找到最小的值并在Stream中返回其密钥。 但我不知道该怎么做，我搜索了API文档但什么也没找到，有人喜欢教我怎么做吗？

Answer 1

尝试：

>>> 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()