当前位置:首页 > java > 正文内容

java stream 流处理数据

root5个月前 (11-30)java1049

Map 类型或者 List类型的数据流式处理

过滤

List<Integer> collect = users.keySet().stream().filter(a -> {
   return a > 2 ;
}).collect(Collectors.toList());

过滤后转map

Map<Integer, User> collect1 = users.keySet().stream().filter(a -> {
   return a > 2;
}).collect(Collectors.toMap(a -> a, b -> users.get(b)));
Map<Integer, User> collect2 = users.keySet().stream().filter(a -> {
   return a > 2;
}).collect(Collectors.toMap(Function.identity(), users::get, (a, b) -> (b)));

转map换key

Map<String, Integer> collect3 = users.keySet().stream().filter(a -> {
   return a > 2;
}).collect(Collectors.toMap(a -> users.get(a).getName(), b -> users.get(b).getId()));

获取更多value的内容,并转换key,value

Map<String, Integer> collect4 = users.keySet().stream().filter(a -> {
   return a > 2;
}).map(b -> users.get(b)).collect(Collectors.toMap(User::getName, User::getId, (a, b) -> a));
Map<String, String> collect5 = users.keySet().stream().filter(a -> {
   return a > 2;
}).map(b -> users.get(b)).collect(Collectors.toMap(a -> a.getName(), b -> b.toString()));


扫描二维码推送至手机访问。

版权声明:本文由一叶知秋发布,如需转载请注明出处。

本文链接:https://zhiqiu.top/?id=254

分享给朋友:

相关文章

java 处理json 字符串

假设有一个实体类public class User{   private int id;   private String name;&...

spring程序开发步骤

1、导入Spring开发的基本包坐标2、编写Dao接口和实现类3、创建Spring核心配置文件4、在Spring配置文件中配置xxDaoImpl5、使用Spring的API获取Bean实例...

spring boot 删除kafka没有消费者的消费组

背景: 服务使用k8s 部署,服务逻辑是广播消费,即每个服务(pod)都会起一个消费组因为每个pod都是一样的,无法固定消费组。同时每次更新或者重启pod时消费组就会增多。时间旧了消费组就会消息堆积,消费组也会越来越多。在项目中启动一个定时...

java 读取json 文件并输出json字符串

import java.io.BufferedReader; import java.io.FileReader; import java.io.IOException; import java...

java-Springboot的几个重要注解@controller、@service、 @repository、@component

1、@controller 控制器(注入服务)用于标注控制层,相当于struts中的action层2、@service 服务(注入dao)用于标注服务层,主要用来进行业务的逻辑处理3、@repository(实现dao访问)用于标注数据访问...

java 发送http 请求

这里以post请求为例例1import cn.hutool.http.HttpRequest; public class HttpRequestUtil {    &...