如何在没有 POJO 类方法的 java 流中使用 Collectors.groupingBy

Question

我正在读取单个 csv 文件（大小约为 700 MB，有 103415834 行）并尝试检索具有某些特定值的所有行。如果它只有 1 个条目，我可以检索该行，但如果它有超过 1 个条目则不能。下面是我的代码，它适用于 1 个条目。    try (Stream<String> stream = Files.lines(Paths.get(IN_FILE_PATH))) {        int nameIndex = columns.indexOf("Rate");        Stream<String> stream1 = Files.lines(Paths.get(IN_FILE_PATH));        List<List<String>> values = stream1                .skip(1)                .map((line) -> Arrays.asList(line.split(",")))                .filter(list -> list.get(nameIndex).equals("25"))                .collect(Collectors.toList());        System.out.println(values.size());        values.forEach((l) -> System.out.println(l));    } catch (IOException e1) {        e1.printStackTrace();    }尝试解析的 csv 文件的示例行如下：MD,URN,PremiseType,Rate,OHP 09022,null,Residential,14,null 38329,1428275,Residential,14,null 38742,563459,Single,21,111

Answer 1

这是按Rate(arr[3]) 分组，但您可以按所需的任何字段分组：

Map<String, List<String>> map = Files.lines(Paths.get(IN_FILE_PATH))

            .skip(1)

            .map(line -> line.split(","))

            .collect(groupingBy(arr -> arr[3], 

                     mapping(strings -> String.join(" ", strings), toList())));

结果中的键map是您分组的字段（在本例中为速率），值（List<String>）是具有相同速率的行列表。

希望这有帮助