时间戳

首页 > 解决方案 > Java：我们如何进一步简化文件的 java 8 流逻辑

java - Java：我们如何进一步简化文件的 java 8 流逻辑

问题描述

我们如何结合下面的 2 个流逻辑：

public void filterRecord(File inputDirectory) throws IOException {

        if (inputDirectory.exists() && !inputDirectory.isDirectory()) {
            List<Path> pathStreams = Files.list(Paths.get(inputDirectory.getAbsolutePath()))
                    .filter(path -> path.toString().endsWith(".csv"))
                    .collect(Collectors.toList());

            for (Path filePath : pathStreams) {

                Files.lines(filePath)
                        .filter(line -> (line != null && !line.isEmpty()))
                        .filter(line -> "10".equals(line.substring(0, line.indexOf(",")).trim()))
                        .forEach(System.out::println);
            }
        }
    }

在上面的代码中，两个 Streams 参与其中，

  1. 第一个流是使用目录路径过滤具有特定扩展名的文件列表。
  2. 第二个流是从文件中过滤内容并在控制台上打印。

标签： javafilejava-streamsimplify

解决方案

public void fileStreamsFilter(Path inputDirectoryPath) throws IOException {

    if (Files.exists(inputDirectoryPath) && Files.isDirectory(inputDirectoryPath)) {

        Files.list(inputDirectoryPath).filter(path -> path.toString().endsWith(".csv"))
        .flatMap(path -> {
            try {
                return Files.lines(path);
            } catch (IOException ioException) {
                log.error(ioException.getMessage(), ioException);
            }
            return null;
        })
        .filter(line -> (line != null && !line.isEmpty()))
        .filter(line -> "10".equals(line.substring(0, line.indexOf(",")).trim()))
        .forEach(log::info);
    }
}

推荐阅读