《stream》专题

问题内容： Java 8引入了一个类似于Scala的Stream的Stream类，它是一个强大的惰性构造，使用它可以非常简洁地执行以下操作： 我想知道是否可以在Java 8中执行此操作，所以我写了如下代码： 相当简单，但它产生的原因是和都是终端操作，只能在该终端上执行一次。 我真的不需要用完两次流，因为我需要的只是流中的第一个数字，其余作为另一个流，即Scala 和的等效项。Java 8 中是否可

问题内容： 我尝试使用Streams API将以下Scala行转换为Java 8： 为了用Java编写等效项，我创建了一个整数范围： 我怀疑在流API中找到了一个方法，但只知道奇怪的方法： 如何使用Java 8 Streams API随机播放列表？ 问题答案： 干得好： 印刷品：

问题内容： 作为非终端操作，我如何检查a 是否为空，如果不是则抛出异常？ 基本上，我在寻找与下面的代码等效的东西，但是没有在它们之间实现流。特别是，检查不应在终端操作实际消耗流之前进行。 问题答案： 如果您可以使用有限的并行功能，则以下解决方案将起作用： 这是一些使用它的示例代码： （有效的）并行执行的问题在于，支持对的拆分需要一种线程安全的方式来注意是否有任何片段以线程安全的方式看到了任何值。然

问题内容： 有人向我解释什么和是谁？ 我感到困惑的用例都和。 如果您还可以包括一段代码来进行解释，那将是很好的。谢谢！ 问题答案： 的目标和是抽象不同的方式来输入和输出：流是一个文件，网页，或者屏幕不应该的事。重要的是您从流中接收信息（或将信息发送到该流中。） 用于阅读许多内容。 用于写很多东西。 这是一些示例代码。它假定和已经创建：

问题内容： 考虑一下此片段- 这导致了NPE。似乎正在这样做，并且既然是，就会抛出NPE。为什么要评估这种情况？第二个表达式是，因此计算为。因此，无论后续操作的真值如何，都将为false。在这种情况下，为什么要进行评估？ 本文和本文声称，如果不需要确定结果，则可能不评估所有表达式。显然，这里似乎并非如此。 在Java 7之前- 这不会抛出NPE，因为是它会返回那里本身。因此，我们可以说这与上述Ja

问题内容： 我有清单 现在，我可以使用Java 8 Streams API将这个List转换成Map，在其中我得到福特= focus，丰田= yaris，尼桑= Micra，本田= Civic吗？ 问题答案： 以下是有关如何执行此操作的示例： 基本上，仅迭代每2个元素并将其与下一个元素映射。 请注意，如果元素数不是偶数，则不会考虑最后一个元素。

问题内容： 我想使用Streams.intRange（int start，int end，int step）实现反向排序的流。但是，似乎java.util.Streams类不再可用（但是它仍在标准库的rt.jar中）。此方法是在其他类中还是被其他方法替代？ 问题答案： 实际上，JDK中再也没有这种方法了。您能获得的下一个最接近的位置是，但是只会一步一步走。 一种解决方案是实施您自己的解决方案。例如

问题内容： 我正在尝试读取一个大文件，并将“引号”中的文本提取出来，并将这些行放入集合中，然后使用Java 8将集合的内容写入文件中。 请帮我。谢谢！ 编辑：问题的答案。 不，没有多引号的文字。 我本可以使用简单的循环。但是我想使用Java 8流 问题答案： 不幸的是，Java正则表达式类不提供匹配结果的流，仅提供一种方法，但您不想拆分。 注意：它已 在Java 9中 作为Matcher.resu

问题内容： 我遇到了以下我不认识的Java语法。 这部分很好： 但是，我没有得到： 这是什么？ 问题答案： 这提供了该类的内联（匿名）子类。 从功能上讲，它与： 和 但是由于该类定义不在方法主体之外使用，因此可以将其定义为匿名。

问题内容： 让我们考虑一个哈希图 我在两个哈希图中都插入了一些值。 例如， Q1）现在我想在哈希图中的键上应用一个筛选条件，并检索相应的值（列表）。 例如：这里我的查询是key = 1，输出应该是“ list1” 我写 但是我不知道如何检索列表作为此流操作的输出。 Q2）同样，我想对hashmap中的键应用过滤条件，并检索相应的列表列表。 例如：这里我的查询是key = 1％（即key可以是1,1

问题内容： 我仍在学习Lambda，请原谅我做错了什么 似乎只能对一条语句执行。它不返回更新的流或函数以进行进一步处理。我可能总共选错了一个。 有人可以指导我如何有效地做到这一点吗？ 还有一个问题， 如何将其转换为Lambda表达式？ 问题答案： 忘记与第一个代码段相关。我根本不会用。由于您将的元素收集到中，因此以结束处理会更有意义。然后，您将需要设置ID。 对于第二个代码段，可以执行多个表达式，

问题内容： 使用所有可用内存后，Redis将如何处理XADD？是否会从流中删除最旧的项目，并添加新的项目？添加后，旧项目仍会存在于AOF文件中吗？它会抛出错误而不添加新项吗？我应该期待什么？ 问题答案： 流是所有其他人一样的数据结构，这样的Redis将尊重并在RAM中的压力的情况下。根据策略，新的写请求将被拒绝，或者现有密钥（是否存在流）将被驱逐。 在https://redis.io/topics

问题内容： 我正在使用fast-csv使用来遍历CSV文件。对于CSV文件的每一行，我想在redis中创建一个作业，为此我使用kue。解析行是同步功能。整个过程看起来像这样： CSV文件每一行的简单显示，但是未创建作业。即，没有打印出回调中的输出，并且该作业不在我的Redis中。 我假设，因为它是CSV文件的最后一行，所以该流已经发出，因此最后一个不能在进程终止之前执行吗？ 有没有办法在完成kue

问题内容： 我想不断详细说明数据集流的行（最初由Kafka发起）：基于条件，我想更新Radis哈希。这是我的代码段（是上一个命令的结果，该命令是这种类型的流：。扩展为）： 我收到一个巨大的堆栈跟踪，相关部分（我认为）是这样的： 谁能解释为什么发生此异常以及如何避免？谢谢！ 问题答案： Spark上下文不可序列化。 ForeachWriter的任何实现都必须可序列化，因为每个任务都将获得所提供对象的

问题内容： 各自的优缺点是什么？请建议何时使用一种而不是另一种。 问题答案： 数据存储 发布/订阅是发布者/订阅者平台，不是数据存储。无论是否有订阅者，发布的消息都会消失。 在Redis Streams中，stream是一种数据类型，它本身就是一种数据结构。消息或条目存储在内存中，并保留在那里直到被命令删除。 同步/异步通信 发布/订阅是同步通信。各方需要同时处于活动状态才能进行通信。Redis在