如何找到 Spark-streaming 中具有最小值的键值对？
How can I find the key-value pairs that have smallest value in Spark-streaming?
我需要找到最小值和 return 它在 Stream 中的键。
但是我不知道该怎么做，我搜索了 API 文档但没有找到，谁愿意教我怎么做？
尝试：
>>> 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()
我需要找到最小值和 return 它在 Stream 中的键。 但是我不知道该怎么做，我搜索了 API 文档但没有找到，谁愿意教我怎么做？
尝试：
>>> 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()