私は持っていObservable<String>ます。Map<String, Int>これを、個別の文字列ごとの出現回数を示すに変えたいと思います。
オブザーバブルには約 10 億個の要素が含まれており、そのうち 1000 個が個別のものです (したがって、データセット全体を RAM に保存することはできません)。現在、 を反復処理してObservable更新しHashMapます。また、競合状態を回避するために、同じスレッドで必ず監視します。ただし、要素周波数の取得は本質的に簡単に並列化できるはずなので、それを利用すると便利です。
それを行う方法はありますか？