Spark-streamingで最小値を持つKey-Valueペアを見つける方法はありますか？

Question

最小の値を見つけてストリームでそのキーを返す必要があります。 しかし、私はそれを行う方法がわからない、私は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()