流处理

作者: 哈迪斯Java | 来源:发表于2021-11-28 18:10 被阅读0次
image.png

流处理的主要接口和类主要分为以上三个

image.png

package All.D14.Steam_;
import java.util.ArrayList;
import java.util.List;

public class Employee { // 员工类
private String name; // 姓名
private int age; // 年龄
private double salary; // 工资
private String sex; // 性别
private String dept; // 部门

// 构造方法
public Employee(String name, int age, double salary, String sex, String dept) {
    this.name = name;
    this.age = age;
    this.salary = salary;
    this.sex = sex;
    this.dept = dept;
}

// 重写此方法,方便打印输出员工信息
public String toString() {
    return "name=" + name + ", age=" + age + ", salary=" + salary + ", sex=" + sex + ", dept=" + dept;
}

// 以下是员工属性的getter方法
public String getName() {
    return name;
}

public int getAge() {
    return age;
}

public double getSalary() {
    return salary;
}

public String getSex() {
    return sex;
}

public String getDept() {
    return dept;
}

public static List<Employee> getEmpList() { // 提供数据初始化方法
    List<Employee> list = new ArrayList<Employee>();
    // 添加员工数据
    list.add(new Employee("老张", 40, 9000, "男", "运营部"));
    list.add(new Employee("小刘", 24, 5000, "女", "开发部"));
    list.add(new Employee("大刚", 32, 7500, "男", "销售部"));
    list.add(new Employee("翠花", 28, 5500, "女", "销售部"));
    list.add(new Employee("小马", 21, 3000, "男", "开发部"));
    list.add(new Employee("老王", 35, 6000, "女", "人事部"));
    list.add(new Employee("小王", 21, 3000, "女", "人事部"));
    return list;
}

}

package All.D14;
import All.D14.Steam_.Employee;

import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;

class Demon01 {
public static void main(String[] args) {
List<Employee> list = Employee.getEmpList(); // 获取公共类的测试数据
Stream<Employee> stream = list.stream(); // 获取集合流对象
// 将年龄大于30岁的员工过滤出来
stream = stream.filter(people -> people.getAge() > 30);
// 将流对象重新封装成一个List集合
List<Employee> result = stream.collect(Collectors.toList());
for (Employee emp : result) { // 遍历结果集
System.out.println(emp); // 输出员工对象信息
}
}
}

name=老张, age=40, salary=9000.0, sex=男, dept=运营部
name=大刚, age=32, salary=7500.0, sex=男, dept=销售部
name=老王, age=35, salary=6000.0, sex=女, dept=人事部

相关文章

  • Flink 原理详解

    Flink 是一个流处理框架,支持流处理和批处理,特点是流处理有限,可容错,可扩展,高吞吐,低延迟。 流处理是处理...

  • 处理流、转换流和输入/输出流体系

    1.处理流 处理流的典型思路: 使用处理流包装节点流,程序通过处理流来执行输入输出功能,让节点流与底层IO...

  • Spark Streaming学习(一)流处理框架,Spark运

    流处理框架 Spark Streaming和其他流处理框架的对比 处理模式: 一种是原生流处理(Native)方式...

  • Spark Streaming实时流处理-1.初识实时流处理

    目录 业务现状分析 实时流处理产生背景 实时流处理概述 离线计算与实时计算对比 实时流处理框架对比 实时流处理架构...

  • Spark权威指南读书笔记(五):流处理

    第二十章 流处理基础 什么是流处理 流处理是连续处理新到来的数据以更新计算结果的行为。在流处理中,输入数据是无边界...

  • Storm介绍之概念

    什么是实时流计算? 主要的处理模式可以分为:流处理,批处理 流处理是直接处理,有时也分为在线,离线,近线(st...

  • 流处理

    流处理的主要接口和类主要分为以上三个 package All.D14.Steam_;import java.uti...

  • IO流——处理流

    处理流之一:缓冲流 处理流,就是“套接”在已有的流的基础上。 1. 缓冲流 BufferedInputStream...

  • 2020-07-20

    spark streaming 结构化流 批量处理为主 flink 流为主,批量处理只是流处理中的一个特例 sto...

  • IO流

    IO 输入是读取,输出是写出,流是单向的 节点流,也叫低级流 节点流有明确的来源与去向 处理流,也叫高级流 处理流...

网友评论

      本文标题:流处理

      本文链接:https://www.haomeiwen.com/subject/soitxrtx.html