草庐IT

ZMQ_STREAM

全部标签

java - 如何方便地对 CompleteableFuture<BigDecimal> 的 Stream 求和?

我正在寻找一种非阻塞方式来对CompleteableFuture的Stream求和.我已经找到与此问题密切相关的主题,例如this.但不幸的是,就我而言,我确实有BigDecimal打包到CompleteableFuture中,因此我需要先等待完成。最后,我想获得另一个CompleteableFuture,它包含Stream中所有Futures的总和,一旦它完成。编辑:实际上我确实设法找到了以下解决方案:Stream>lotOfWork;CompletableFuture.supplyAsync(()->lotOfWork.map(CompletableFuture::join).re

java - 使用 Java 8 Stream 读取文本文件 block

Java8有一种方法可以从文件的行创建流。在这种情况下,foreach将逐行执行。我有一个具有以下格式的文本文件..bunchoflineswithtext$$$$bunchoflineswithtext$$$$我需要将$$$$之前的每组行放入Stream中的单个元素中。换句话说,我需要一个字符串流。每个字符串都包含$$$$之前的内容。执行此操作的最佳方法(开销最小)是什么? 最佳答案 我想不出一个延迟处理线条的解决方案。我不确定这是否可行。我的解决方案生成一个ArrayList。如果您必须使用Stream,只需对其调用stream

java - 我可以按元素的类过滤 Stream<T> 并一步获得 Stream<U> 吗?

这个问题在这里已经有了答案:IsthereaJavaStreammethodequivalenttoScala'scollections"collect"?(5个答案)关闭7年前。假设我有classDogextendsAnimal{}classCatextendsAnimal{}我有一份动物list使用GuavaFluentIterable我可以一步过滤和转换Listcats=FluentIterable.from(animals).filter(Cat.class).toList();使用Java8我需要做Listcats=animals.stream().filter(c->cin

java - 为什么 Kafka Direct Stream 会为每条消息创建一个新的解码器?

我有一个用Java编写并使用Spark2.1的Spark流应用程序。我正在使用KafkaUtils.createDirectStream来读取来自Kafka的消息。我正在为kafka消息使用kryo编码器/解码器。我在Kafkaproperties->key.deserializer,value.deserializer,key.serializer,value.deserializer中指定了这个当Spark在微批中拉取消息时,使用kryo解码器成功解码消息。但是我注意到Spark执行程序创建了一个新的kryo解码器实例,用于解码从kafka读取的每条消息。我通过将日志放入解码器构造

java - NoClassDefFoundError : javax/xml/stream/XMLStreamException

尝试使用ApachePOI编写.xlsx文件时出现以下异常NoClassDefFoundError:javax/xml/stream/XMLStreamException这是代码片段:-XSSFWorkbookwb=newXSSFWorkbook();Sheetsheet=wb.createSheet();Rowrow=sheet.createRow(0);Cellcell=row.createCell(0);cell.setCellValue(100);FileOutputStreamfileOut=newFileOutputStream("D:\\workspace\\April\

java - 一个 Stream 是否可以顺序处理一部分流水线,然后并行处理?

我有以下代码无法按预期工作(跳过随机行,而不是第一行):Files.lines(path).skip(1).parallel().forEach(System.out::println)我感觉我误解了Streams的行为。问题是:我能否先将流视为顺序流(并使用“有状态的中间操作”),然后将其送入并行forEach? 最佳答案 整个管道要么是并行的,要么是顺序的。尝试使用forEachOrdered而不是forEach。在我的测试中,如果使用forEachOrdered它会跳过第一行(对于forEach它会跳过最后一行)。forEac

java - 如何限制 Stream 顺序运行,并防止它并行运行?

我有一个方法可以返回从自定义拆分器生成的流;分离器不安全。由于spliterator不安全,并且它保持状态,我想防止它并行运行。有没有办法防止返回的流并行运行?我没能找到执行此操作的任何文档或示例。我确实在BaseStream类上找到了一个sequential()方法,但这似乎并没有阻止用户调用parallel()来得到一个并行流。 最佳答案 并行流调用拆分器的trySplit()方法将您的任务拆分为多个部分。这是absolutelylegit从trySplit()返回null表示“我拒绝拆分”。在这种情况下,即使显式调用了.par

java - 是否有更高效的 Java 8 Stream 方法来查找 int[] 中的索引?

基于BlackJackQuestion,我想知道如何指示所有获胜的手。实际上,最初的问题只是询问两个不大于21的数字中的最大值。所以像这样的方法publicintblackjack(inta,intb);但是,如果有人希望返回所有获胜的手(假设输入数组中的位置是table上的一个座位),那么签名如:/***returnsanarrayindicatetheindexinthespecifiedhandsthat*correspondtothewinninglocations.Willreturnanemptyarrayif*therearenowinners.Thelengthofth

java - 如何在 Java 8 Stream.flatMap(..) 中捕获异常

给定一个Stream和一个返回Stream作为数据源的不同参数的方法,我正在寻找一种通过flatMap合并流的方法(..)并在执行期间捕获某些Exceptions。让我们看下面的代码片段:publicclassFlatMap{publicstaticvoidmain(finalString[]args){longcount;//thismightthrowanexceptioncount=Stream.of(0.2,0.5,0.99).flatMap(chance->getGenerator(chance,20)).count();//tryingtocatchtheexception

java - 使用 Java8 stream api 将函数列表应用于值

我想要一个单条日志消息pojoLoggedExchange并对其应用一系列转换。转换是列表中的一元运算符:Listtransforms=newArrayList();哪里ConditionalTransform工具UnaryOperator我目前的解决方案是像这样使用reduce:publicLoggedExchangetransform(LoggedExchangeoriginal){returntransforms.stream().reduce(original,(o,t)->t.apply(o),(m1,m2)->m2);}并行运行它没有意义,因为无法合并两条消息((m1,m2