Ignite Cache値の合計

Question

Igniteチュートリアルコード（下記のリンク）を使用していますが、異なるタイプのデータで動作し、カウントが異なるように修正したいと思います。現在の値を追加します。

それでは、私は別の文書内の特定の単語の出現箇所の数を持っていると仮定しましょう、それでは、私はこのような何かがあると仮定してみましょう：

「」6586

を「」925

だから私は、だから、この与えられたキャッシュは、 '' 7511

を を保持したい：

try (Stream<String> lines = Files.lines(path)) { 
      lines.forEach(line -> { 
       Stream<String> words = Stream.of(line.split(" ")); 
       List<String> tokens = words.collect(Collectors.toList()); 
       // this is just to emphasize that I want to pass value 
       Long value = Long.parseLong(tokens.get(1)); 
       stmr.addData(tokens.get(0), Long.parseLong(tokens.get(1)); 

Iはstmr.receiver（）メソッドに渡される値したいので、私はヴァルに追加することができます。

値を保存するクラス変数をStreamWordsで作成しようとしましたが、値は更新されず、stmr.receiver（）ではまだ0（初期化済み）です。チュートリアルへ

リンク： Word Count Ignite Example

Answer 1

私はそれを把握するために管理。 stmr.receiver（）では、argは実際には私が挿入したい値なので、あなたの欲望のオブジェクトにキャストするだけで、値を取得できるはずです。