《stream》专题

问题内容： 我正在学习Java 8 lambda表达式，我想问一下以下与我遇到的函数接口中的方法有关的Java代码。 在IDE上执行程序时，它不输出。我期望它会给。 问题答案： 我假设您正在Java 9下运行它？您没有更改流的属性，因此不需要执行任何一个或全部执行。 换句话说，您关心的只是最终结果，但与此同时，您不以 任何 方式（例如通过或）更改的初始大小。这是在Streams中完成的优化。 顺便

问题内容： 我刚刚使用了解了输入/输出。 我想知道究竟是什么术语的含义和？ 这行代码还为我们提供了什么： 问题答案： Java有两种用于输入和输出（I / O）的类： 流 和 读取器/ 写入 器 。 流（，以及延伸这些一切）用于读取和文件，网络或任何其他设备写入二进制数据。 读者和作家用于阅读和书写文本（字符）。它们是流之上的一层，它使用字符编码将二进制数据（字节）转换为字符，再转换回字符。 从磁

问题内容： 像几乎每个人一样，我仍在学习新的Java 8 Streams API的复杂性（并喜欢它们）。我对流的使用有疑问。我将提供一个简化的示例。 Java Streams允许我们采用，并在其上使用方法来接收其所有元素的流。在这，有许多有用的方法，比如，和，这让我们对内容的使用拉姆达操作。 我有看起来像这样的代码（简化）： 这个想法是获取集合中与某个限定符匹配的所有项目的映射，然后对它们进行操作

问题内容： 我喜欢Java 8的流API。有很多有用的中间方法和终端方法来转换和收集流。我说的是中间方法distinct()或终端方法collect()。我发现该CollectorAPI特别有用，可以将流减少为深度分组图。 Java流API的javascript等价物是什么？我知道好像有很基本的功能map，filter以及reduce，但没有发现由JavaScript原生的收集提供的查询或一组数据

问题内容： 我已经max对Java 8 lambda和流上的功能进行了一些测试，并且似乎在max执行情况下，即使有多个对象与0比较，它也会在绑定的候选对象中返回任意元素，而无需进一步考虑。 对于这样的最大预期行为，是否有明显的技巧或功能，以便返回所有最大值？我在API中看不到任何内容，但是我确信它必须比手动比较更好。 例如： 问题答案： 我将按值分组并将值存储到TreeMap中，以便对值进行排序，

问题内容： 假设您有一个数字。中的值可以是类型，等等。声明时，可以使用通配符（）声明，也可以不使用通配符。 所以，现在我想在和它所有的使用（显然下面的代码只是为了说明问题的例子）。让我们开始流式传输： 但是，我不能在：上执行相同的操作 编译器在调用时抱怨以下消息： Test.java：找不到符号 symbol：方法intValue（） 位置：java.lang.Object类型的变量编号 从编译器

问题内容： 对于我的示例，拥有汽车对象，并根据模型（分组依据）发现了最小和最大价格值。 但是我找不到哪个汽车对象具有最高和最低价格。我怎样才能做到这一点？ 问题答案： 如果您只对每个组感兴趣，则可以使用，例如 但是，由于您想要最昂贵和最便宜的产品，因此需要以下内容： 由于没有与之等效的通用统计对象，因此该解决方案带来了一些不便。如果这种情况不止一次发生，那么值得用这样的类填补空白： 将其添加到您的

问题内容： 从管道获取可能会返回StreamSpliterators.WrappingSpliterator的实例。例如，获取以下内容： 鉴于以上所述，当我们通过的方法（在本例中为StreamSpliterators.WrappingSpliterator的一个实例）单独遍历元素时，它将首先将项目累积到内部缓冲区中，然后再使用这些项目，如我们在StreamSpliterators.java中所看到

问题内容： 我正在用它来获取最新的物品。我如何才能做到这一点是null安全的，最后（最旧）的日期排序为null。createDt是一个joda LocalDate对象。 问题答案： 如果可能为，则使用@rgettman的解决方案。 如果可能为null，则使用以下代码： 在任何一种情况下，请注意，由于大多数标准实现会首先对整个流进行排序，因此效率可能很低。您应该改用Stream.min。

问题内容： 我有一个kafka stream应用程序，等待有关topic的记录被发布。它将接收json数据，并根据我想将该流推送到不同主题的键的值来确定。 这是我的流应用程序代码： 在此代码中，我要检查操作类型，然后根据需要将流推送到相关主题中。 我该如何实现？ 编辑： 我已将代码更新为： 问题答案： 您可以使用方法来拆分流。此方法使用谓词将源流分成几个流。 以下代码取自kafka-streams

问题内容： 如我所见，使用Java 8时，显而易见的代码无论是“对象”流还是原始流（即和朋友），都将仅使用： 但随后，也有不少“可流动资源” 。 读取javadoc时不清楚的是流是否始终是顺序的，以及流是否始终是并行的… 然后是尤其是它之一，它可以是甚至是它。 我的直觉是，事实上，无论a是否可以默认并行，还是完全并行，都是由其底层… 我在正确的轨道上吗？我已经阅读并再次阅读了javadocs，但仍

问题内容： 回顾Java 8 API设计，我对参数的通用不变性感到惊讶： 同一API的看似更通用的版本可能对的单个引用应用了协方差/协方差，例如： 目前，这将允许以下操作（不可能）： 解决方法，使用方法引用将类型“强制”为目标类型： C＃没有使用声明位置方差定义如下的特定问题，这意味着使用此方法的任何API 都可以免费获得此行为： 与建议的设计相比，现有设计有哪些优势（可能还有进行EG决策的原因）

问题内容： 我有以下内容： 但是，并非总是有一个结果会给我以下错误： NoSuchElementException：没有值 那么，如果没有值，我该如何返回？ 问题答案： 您可以使用，它比检查要简单得多：

问题内容： 关于s，当我执行这段代码时 我得到这个输出 因为将我的信息流限制在前三个部分，因此操作 A ， B 和 C 只能执行3次。 尝试使用method 在最后三个元素上执行类似的计算，显示了不同的行为： 输出这个 在这种情况下，为什么要执行动作 A1 至 A6 ？它与 限制 是一种短路的有状态中间操作有关，而 跳过 不是，但我不了解此属性的实际含义。仅仅是“ 执行 跳过 前的每个动作，而不是

问题内容： 我想在每次迭代中将的值增加。轻松实现。变量是的数组。 这是我的。 为了练习Stream，我尝试将其重写为： 导致我的错误： 错误：从lambda表达式引用的局部变量必须是final或有效的final 如何重写要在其中使用的递增变量？ 问题答案： 你不应该 两者看起来很相似，但是在概念上是不同的。循环只是一个循环，但是一条指令指示库对每个元素执行操作， 而不指定操作顺序（对于并行流）或