如何在 Java 流中记录已过滤的值

java java-8 java-stream

2022-09-01 18:21:59

我对Java流中的过滤值有要求。我能够使用方法对非过滤值。但是，有人可以让我知道如何记录过滤值吗？log/sysoutlog/sysoutpeek()

例如，假设我有一个这样的对象列表：Person

List<Person> persons = Arrays.asList(new Person("John"), new Person("Paul"));

我想过滤掉那些不是“约翰”的人，如下所示：

persons.stream().filter(p -> !"John".equals(p.getName())).collect(Collectors.toList());

但是，我必须记录被过滤的“约翰”人的详细信息。有人可以帮我做到这一点吗？

答案 1

如果要将其与 Stream API 集成，除了手动引入日志记录之外，您能做的不多。最安全的方法是在方法本身中引入日志记录：filter()

List<Person> filtered = persons.stream()
      .filter(p -> {
          if (!"John".equals(p.getName())) {
              return true;
          } else {
              System.out.println(p.getName());
              return false;
          }})
      .collect(Collectors.toList());

请记住，向 Stream API 引入副作用是不可靠的，您需要了解自己在做什么。

您还可以构造一个通用包装器解决方案：

private static <T> Predicate<T> andLogFilteredOutValues(Predicate<T> predicate) {
    return value -> {
        if (predicate.test(value)) {
            return true;
        } else {
            System.out.println(value);
            return false;
        }
    };
}

然后简单地说：

List<Person> persons = Arrays.asList(new Person("John"), new Person("Paul"));

List<Person> filtered = persons.stream()
  .filter(andLogFilteredOutValues(p -> !"John".equals(p.getName())))
  .collect(Collectors.toList());

...甚至使操作可自定义：

private static <T> Predicate<T> andLogFilteredOutValues(Predicate<T> predicate, Consumer<T> action) {
    Objects.requireNonNull(predicate);
    Objects.requireNonNull(action);

    return value -> {
        if (predicate.test(value)) {
            return true;
        } else {
            action.accept(value);
            return false;
        }
    };
}

然后：

List<Person> filtered = persons.stream()
  .filter(andLogFilteredOutValues(p -> !"John".equals(p.getName()), System.out::println))
  .collect(Collectors.toList());

答案 2

您可以使用

Map<Boolean,List<Person>> map = persons.stream()
    .collect(Collectors.partitioningBy(p -> "John".equals(p.getName())));
System.out.println("filtered: " + map.get(true));
List<Person> result = map.get(false);

或者，如果您更喜欢单语句形式：

List<Person> result = persons.stream()
    .collect(Collectors.collectingAndThen(
        Collectors.partitioningBy(p -> "John".equals(p.getName())),
        map -> {
            System.out.println("filtered: " + map.get(true));
            return map.get(false);
        }));