-1
最小の値を見つけてストリームでそのキーを返す必要があります。 しかし、私はそれを行う方法がわからない、私はAPIドキュメントを検索したが、何も見つからない、誰かが私にそれを行う方法を教えたいですか?Spark-streamingで最小値を持つKey-Valueペアを見つける方法はありますか?
最小の値を見つけてストリームでそのキーを返す必要があります。 しかし、私はそれを行う方法がわからない、私はAPIドキュメントを検索したが、何も見つからない、誰かが私にそれを行う方法を教えたいですか?Spark-streamingで最小値を持つKey-Valueペアを見つける方法はありますか?
試してみてください。
>>> 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()
私はあなたがあなたの研究を行うと、このような特定の問題ではなく、一般的な解決策を求める必要があり、質問のこの種のは、ここで適切ではないと思います。 – 4c74356b41