stream 流式计算
2021/4/28 10:27:24
本文主要是介绍stream 流式计算,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
新时代程序员必须掌握:lambda 表达式、链式编程、函数式接口、Stream 流式计算
为什么要使用流式计算?
大数据: 存储+计算 集合、MySQL本质就是存储东西的; 计算都应该交给流来操作!
现在通过下面的题来了解链式编程。
/** * 题目要求:现在有5个用户!筛选; * 1、ID 必须是偶数 * 2、年龄必须大于23岁 * 3、用户名转为大写字母 * 4、用户名字母倒着排序 * 5、只输出一个用户! */ @Data @AllArgsConstructor @NoArgsConstructor public class User { private int id; private String name; private int age; }
filter(完成id是偶数,年龄大于23的过滤)
- Stream
filter(Predicate<? super T> predicate) - 一般适用于list集合,主要作用就是模拟sql查询,从集合中查询想要的数据。(过滤)
- 我们可以看到参数是一个函数式接口
public class StreamExample { public static void main(String[] args) { User user1 = new User(1, "a", 21); User user2 = new User(2, "b", 26); User user3 = new User(3, "c", 23); User user4 = new User(4, "d", 24); User user5 = new User(5, "e", 25); List<User> list = Arrays.asList(user1, user2, user3, user4, user5); //流式计算 list.stream() .filter(user -> {return user.getId()%2 == 0;}) .filter(user -> {return user.getAge()>23;}) .forEach(System.out::println); } }
结果如下 User(id=2, name=b, age=26) User(id=4, name=d, age=24)
map 输出的名字大写
Stream map(Function<? super T,? extends R> mapper) - Stream中map可用于元素类型转化方法
- 我们可以看到参数是一个函数式接口
public class StreamExample { public static void main(String[] args) { User user1 = new User(1, "a", 21); User user2 = new User(2, "b", 26); User user3 = new User(3, "c", 23); User user4 = new User(4, "d", 24); User user5 = new User(5, "e", 25); List<User> list = Arrays.asList(user1, user2, user3, user4, user5); //流式计算 list.stream() .filter(user -> {return user.getId()%2 == 0;}) .filter(user -> {return user.getAge()>23;}) .map(user -> {return user.getName().toUpperCase();}) .forEach(System.out::println); } }
结果 B D
sorted 用sorted完成倒序(默认是顺序)
- Stream
sorted() - 返回由此流的元素组成的流,根据自然顺序排序。
- 如果该流的元件不是
Comparable
,一个java.lang.ClassCastException
执行终端操作时,可以抛出。 - 对于有序流(list),排序稳定。 对于无序的流,不能保证稳定性。
public class StreamExample { public static void main(String[] args) { User user1 = new User(1, "a", 21); User user2 = new User(2, "b", 26); User user3 = new User(3, "c", 23); User user4 = new User(4, "d", 24); User user5 = new User(5, "e", 25); List<User> list = Arrays.asList(user1, user2, user3, user4, user5); //流式计算 list.stream() .filter(user -> {return user.getId()%2 == 0;}) .filter(user -> {return user.getAge()>23;}) .map(user -> {return user.getName().toUpperCase();}) .sorted((u1,u2)->{return u2.compareTo(u1);}) .forEach(System.out::println); } }
结果 D B
limit 只输出一个用户
- Stream
limit(long maxSize) - 返回由该流的元素组成的流,截断长度不能超过
maxSize
。
public class StreamExample { public static void main(String[] args) { User user1 = new User(1, "a", 21); User user2 = new User(2, "b", 26); User user3 = new User(3, "c", 23); User user4 = new User(4, "d", 24); User user5 = new User(5, "e", 25); List<User> list = Arrays.asList(user1, user2, user3, user4, user5); //流式计算 list.stream() .filter(user -> {return user.getId()%2 == 0;}) .filter(user -> {return user.getAge()>23;}) .map(user -> {return user.getName().toUpperCase();}) .sorted((u1,u2)->{return u2.compareTo(u1);}) .limit(1) .forEach(System.out::println); } }
结果 D
参考教程:https://www.kuangstudy.com/
这篇关于stream 流式计算的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-05-15鸿蒙生态设备数量超8亿台
- 2024-05-13TiDB + ES:转转业财系统亿级数据存储优化实践
- 2024-05-09“2024鸿蒙零基础快速实战-仿抖音App开发(ArkTS版)”实战课程已上线
- 2024-05-09聊聊如何通过arthas-tunnel-server来远程管理所有需要arthas监控的应用
- 2024-05-09log4j2这么配就对了
- 2024-05-09nginx修改Content-Type
- 2024-05-09Redis多数据源,看这篇就够了
- 2024-05-09Google Chrome驱动程序 124.0.6367.62(正式版本)去哪下载?
- 2024-05-09有没有大佬知道这种数据应该怎么抓取呀?
- 2024-05-09这种运行结果里的10.100000001,怎么能最快改成10.1?