.stream.filter.filter什么意思

在Java Stream API中，`.stream().filter(filter).filter(filter)`连续调用两次`filter`方法是用来对流进行过滤操作的。这里的第一个`filter(predicate)`接受一个谓词（Predicate），用于筛选出满足条件的元素。然后，第二次的`filter`也是同样的过程，它会对前一次过滤后的结果再次应用另一个谓词，进一步筛选数据。

例如：

List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);
numbers.stream()
       .filter(n -> n > 2) // 过滤掉不大于2的数
       .filter(n -> n % 2 == 0) // 再次过滤掉奇数
       .forEach(System.out::println); // 输出偶数：4, 6

这里首先保留大于2的数，然后再保留能被2整除的数。如果不希望连续调用两次，可以将第二个`filter`替换为一个单独的`filter`，并将两个谓词组合成一个复合谓词：

numbers.stream()
       .filter(n -> n > 2 && n % 2 == 0)
       .forEach(System.out::println);

相关问题

java list.stream().filter和list.stream().peek却别

在Java 8的Stream API中，`filter()` 和 `peek()` 都是用来操作集合的高阶函数，但它们的作用略有区别。

1. **`filter(Predicate<T>)`:** 这个方法用于过滤流中的元素。它接受一个谓词（Predicate），这个谓词是一个返回布尔值的函数，如果元素满足这个条件（谓词返回true），则会被包含在结果流中。举个例子，如果你想从列表中筛选出所有的偶数，你可以这样做：

   List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);
   List<Integer> evenNumbers = numbers.stream()
       .filter(n -> n % 2 == 0)
       .collect(Collectors.toList());

结果将是 `[2, 4]`。

2. **`peek(Consumer<T>):**** 这个方法应用于每个元素上，但它并不改变元素本身或流的结构。`peek()` 接收一个消费者（Consumer），该消费者对每个元素执行一些副作用操作（例如打印、计数等），而不会影响实际的流结果。例如：

   List<String> words = Collections.singletonList("hello");
   words.stream()
       .peek(System.out::println)
       .forEach(System.out::println);  // 打印 "hello" 后，再打印列表中原有的每一个元素

输出将是：

   hello
   hello

总结来说，`filter()` 改变了流的内容，而 `peek()` 只是做了额外的操作但不影响最终结果。如果你关心的是过滤后的数据，用 `filter()`；如果你需要对元素做些额外操作但结果不变，用 `peek()`。

优化以下代码： FileMatrixVo fileMatrixVo = new FileMatrixVo(); fileMatrixVo.setId(tableName + "-" + columnName); fileMatrixVo.setCoherenceFiles(errorOutputFiles.stream().filter(errorOutputFileVo -> RuleTemplateName.ENUMERATION_CHECK.getId().equals(errorOutputFileVo.getRuleTemplateId())).collect(Collectors.toList())); fileMatrixVo.setEffectiveFiles(errorOutputFiles.stream().filter(errorOutputFileVo -> RuleTemplateName.REGEXP_CHECK.getId().equals(errorOutputFileVo.getRuleTemplateId())).collect(Collectors.toList())); fileMatrixVo.setCompleteFiles(errorOutputFiles.stream().filter(errorOutputFileVo -> RuleTemplateName.NULL_CHECK.getId().equals(errorOutputFileVo.getRuleTemplateId())).collect(Collectors.toList())); fileMatrixVo.setUniquenessFiles(errorOutputFiles.stream().filter(errorOutputFileVo -> RuleTemplateName.UNIQUENESS_CHECK.getId().equals(errorOutputFileVo.getRuleTemplateId())).collect(Collectors.toList())); fileMatrixVo.setMultiTableConsistency(errorOutputFiles.stream().filter(errorOutputFileVo -> RuleTemplateName.MULTI_TABLE_ACCURACY.getId().equals(errorOutputFileVo.getRuleTemplateId())).collect(Collectors.toList())); fileMatrixVo.setFieldLengthFiles(errorOutputFiles.stream().filter(errorOutputFileVo -> RuleTemplateName.FIELD_LENGTH_CHECK.getId().equals(errorOutputFileVo.getRuleTemplateId())).collect(Collectors.toList())); fileMatrixVo.setTimelinessFiles(errorOutputFiles.stream().filter(errorOutputFileVo -> RuleTemplateName.TIMELINESS_CHECK.getId().equals(errorOutputFileVo.getRuleTemplateId())).collect(Collectors.toList()));

可以将重复的代码抽取到一个方法中，减少代码冗余，如下：

private List<ErrorOutputFileVo> filterErrorOutputFiles(List<ErrorOutputFileVo> errorOutputFiles, String ruleTemplateId) {
    return errorOutputFiles.stream()
            .filter(errorOutputFileVo -> ruleTemplateId.equals(errorOutputFileVo.getRuleTemplateId()))
            .collect(Collectors.toList());
}

...

FileMatrixVo fileMatrixVo = new FileMatrixVo();
fileMatrixVo.setId(tableName + "-" + columnName);
fileMatrixVo.setCoherenceFiles(filterErrorOutputFiles(errorOutputFiles, RuleTemplateName.ENUMERATION_CHECK.getId()));
fileMatrixVo.setEffectiveFiles(filterErrorOutputFiles(errorOutputFiles, RuleTemplateName.REGEXP_CHECK.getId()));
fileMatrixVo.setCompleteFiles(filterErrorOutputFiles(errorOutputFiles, RuleTemplateName.NULL_CHECK.getId()));
fileMatrixVo.setUniquenessFiles(filterErrorOutputFiles(errorOutputFiles, RuleTemplateName.UNIQUENESS_CHECK.getId()));
fileMatrixVo.setMultiTableConsistency(filterErrorOutputFiles(errorOutputFiles, RuleTemplateName.MULTI_TABLE_ACCURACY.getId()));
fileMatrixVo.setFieldLengthFiles(filterErrorOutputFiles(errorOutputFiles, RuleTemplateName.FIELD_LENGTH_CHECK.getId()));
fileMatrixVo.setTimelinessFiles(filterErrorOutputFiles(errorOutputFiles, RuleTemplateName.TIMELINESS_CHECK.getId()));