草庐IT

STREAM_ALARM

全部标签

java - 为什么 Postgres Replication Stream 在单独的函数中使用时不起作用?

我正在研究postgres复制流API。在处理它时遇到了异常行为。当我使用复制槽在主block内编写整个代码时,一切正常。publicclassServerimplementsConfig{publicstaticvoidmain(String[]args){Propertiesprop=newProperties();prop.load(newFileInputStream(System.getProperty("prop")));Stringuser=prop.getProperty("user");Stringpassword=prop.getProperty("password

java - 为什么我得到 java.io.IOException : Stream closed?

我正在尝试下载一个zip文件,但我收到了一个流关闭异常。当我使用swinggui时,它会出现此错误,但如果我使用控制台,则没有问题。为什么我会得到这个异常(exception)?我该如何解决?这是我的代码:URLConnectionconn=url.openConnection();InputStreamin=conn.getInputStream();FileOutputStreamout=newFileOutputStream(destination.getPath());byte[]b=newbyte[1024];intcount;while((count=in.read(b))

java - 使用 Java stream API 像 SQL GROUP BY 一样汇总数据

使用SQL,我可以编写以下代码来汇总数据:SELECTsum(f1),sum(f2),f3,f4FROMTABLEXGROUPBYf3,f4这将返回一个列表,每行有4个值:sum1、sum2、v3、v4例如:这是表中的内容:1,2,a,b1,2,a,b2,2,c,d2,2,c,d3,4,c,d结果将是:2,4,a,b7,8,c,d现在假设我的数据不是数据库表,而是Java对象列表中的变量f1、f2、f3、f4。JavastreamAPI中有没有函数可以根据f3、f4来汇总这个列表? 最佳答案 仅使用JDK的StreamAPI执行此操

java - 在stream中查找对应于post-map minimum的pre-map元素

我经常发现自己在做这样的事情:list.stream().min(newComparator(){@Overridepublicintcompare(Ea,Eb){returnDouble.compare(f(a),f(b));}})其中f是计算密集型函数。这需要对f的计算次数是实际需要的两倍。我更愿意list.stream().mapToDouble(f).min()但是后来不知道怎么得到这个最小值对应的原始元素。一个丑陋的解决方法是classWithF{privatefinalEe;privatefinaldoublefe;WithF(Ee,doublefe){this.e=e;t

nginx启动报错nginx: [emerg] unknown directive “stream“ in /usr/local/project/nginx/conf/nginx.conf:159

原因是在nginx的配置文件中添加了配置stream块之后,启动nginx服务,出现异常信息:nginx:[emerg]unknowndirective"stream"in/usr/local/project/nginx/conf/nginx.conf:159查看nginx的版本信息./nginx-V从nginx官方网址下载nginx安装包,本示例下载:nginx-1.24.0.tar.gz将下载好的压缩包通过ssh远程传输到Linux系统,然后解压首先先备份以前旧的安装的nginx目录mvnginxnginx.back解压上传的压缩包文件tar-zxvfnginx-1.24.0.tar.gz

java - 使用 Java Stream 从一组集合中收集所有对象

我正在尝试学习JavaStreams并尝试获得HashSet来自HashSet>.HashSetstudents=getAllStudents();HashSet>teachersForStudents=students.stream().map(Person::getTeachers).collect(Collectors.toCollection(HashSet::new));HashSet=//combineteachersandstudentsinoneHashSet我真正想要的是将所有老师和所有学生合二为一HashSet.我想我在收集流时做错了什么?

具有自定义逻辑的 Java 8 Stream groupingBy

我有一个Records的列表.其中有两个字段:LocalDateTimeinstant和一个Doubledata.我想按小时对所有记录进行分组并创建一个Map.其中键(Integer)是小时,值(Double)是该小时的最后数据-该小时的第一个数据。到目前为止我所做的如下:FunctionkeyFunc=rec->rec.getInstant().getHour();Map>valueMap=records.stream().collect(Collectors.groupingBy(keyFunc));我希望值映射包含Double而不是List.例如:列表记录可以是:InstantD

java - 为什么 Collection<T> 不实现 Stream<T>?

这个问题在这里已经有了答案:Whydoesn'tjava.util.CollectionimplementthenewStreaminterface?(1个回答)关闭7年前。这是一个关于API设计的问题。当在C#中添加扩展方法时,IEnumerable获取所有启用直接在所有集合上使用lambda表达式的方法。随着Java中lambda和默认方法的出现,我希望Collection将实现Stream并为其所有方法提供默认实现。这样,我们就不需要调用stream()来利用它提供的功能。图书馆架构师选择不太方便的方法的原因是什么?

java - Collectors.toList() 中 LongStream VS Stream 的区别

为什么当我使用Collectors.toList()从LongStream获取列表时出现错误,但使用Stream时没有错误?例子:错误:Something.mapToLong(Long::parseLong).collect(Collectors.toList())正确:Something.map(Long::valueOf).collect(Collectors.toList()) 最佳答案 StreamAPI中有四个不同的类:Stream,IntStream,LongStream和DoubleStream.后三个用于处理原始值i

Java 8 - 从 Collection.stream.map() 调用多参数方法

我使用Java8Streams已有一段时间了。我遇到过这样一种情况,我需要通过List流式传输并将每个元素与另一个参数一起传递给静态方法。在Java8中有可能吗?........Stringdesignation="Engineer";Listnames=newArrayList();names.add("ABC");names.add("DEF");names.add("GHI");names.stream().map(MyClass::createReport);..........classMyClass{publicstaticvoidcreateReport(Stringna