用java写一个数据流示例

假设我们有一个数据文件（data.csv），其中包含了一些用户的基本信息，例如用户名、年龄、性别等。我们可以使用 Java 中的流式处理 API 来读取这个数据文件，并对数据进行处理。具体代码如下：

import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;
import java.util.stream.Stream;

public class DataStreamExample {

    public static void main(String[] args) throws IOException {

        // 打开数据文件
        BufferedReader br = new BufferedReader(new FileReader("data.csv"));

        // 创建数据流
        Stream<String> dataStream = br.lines();

        // 处理数据流
        dataStream
                .skip(1) // 跳过第一行标题行
                .map(line -> line.split(",")) // 将每行数据拆分成数组
                .filter(fields -> Integer.parseInt(fields[2]) > 18) // 仅保留年龄大于 18 的用户
                .forEach(fields -> System.out.println("用户名：" + fields[0] + "，性别：" + fields[1] + "，年龄：" + fields[2]));

        // 关闭数据文件
        br.close();
    }
}

在这个例子中，我们首先打开数据文件，然后使用 BufferedReader 将数据文件转换成一个数据流。接着，我们对数据流进行处理，首先使用 skip 方法跳过第一行标题行，然后使用 map 方法将每行数据拆分成数组。接着，我们使用 filter 方法过滤出年龄大于 18 的用户，最后使用 forEach 方法遍历数据流并输出结果。