点燃缓存值总和答案

【问题标题】：Ignite Cache Sum of values点燃缓存值总和
【发布时间】：2023-03-26 00:25:02
【问题描述】：

我正在使用 Ignite 教程代码（下面的链接），但我想对其进行修改，使其对不同类型的数据进行操作，并且计数的完成方式不同 - 而不是将计数器增加 1 我想添加一个当前值.

所以让我们假设我在不同的文档中有某个单词出现的次数，所以让我们假设我有这样的东西：

'the' 6586

'那个'925

所以我希望 Cache 持有 '那个' 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));

我想将 value 传递给 stmr.receiver() 方法，所以我可以将它添加到 val。

我什至尝试在 StreamWords 中创建一个可以存储值的类变量，但是该值没有得到更新，并且在 stmr.receiver() 中它仍然是 0（初始化时）。

教程链接： Word Count Ignite Example

【问题讨论】：

标签： java ignite

【解决方案1】：

我设法弄明白了。在stmr.receiver()中，arg其实就是我要插入的值，所以只要把它转换成你想要的对象，你应该就能得到这个值了。

【讨论】：