如何在流上重用过滤器和映射的应用程序？

我有一组从共享类型继承的域对象（即GroupRecord extends Record, RequestRecord extends Record）。子类型具有特定的属性（即GroupRecord::getCumulativeTime, RequestRecord::getResponseTime).

此外，作为解析日志文件的结果，我有一个具有混合子类型的记录列表。

List<Record> records = parseLog(...);

为了计算日志记录的统计信息，我想仅对与特定子类型匹配的记录子集应用数学函数，即仅对GroupRecords。因此我想要有一个特定子类型的过滤流。我知道我可以申请filter and map到子类型使用

records.stream()
       .filter(GroupRecord.class::isInstance)
       .map(GroupRecord.class::cast)
       .collect(...

在流上多次应用此过滤器和转换（特别是在针对不同计算多次对同一子类型执行此操作时）不仅很麻烦，而且会产生大量重复。

我目前的方法是使用TypeFilter

class TypeFilter<T>{

    private final Class<T> type;

    public TypeFilter(final Class<T> type) {
        this.type = type;
    }

    public Stream<T> filter(Stream<?> inStream) {
        return inStream.filter(type::isInstance).map(type::cast);
    }
}

应用于流：

TypeFilter<GroupRecord> groupFilter = new TypeFilter(GroupRecord.class); 

SomeStatsResult stats1 = groupFilter.filter(records.stream())
                                      .collect(...)
SomeStatsResult stats2 = groupFilter.filter(records.stream())
                                      .collect(...)

它有效，但我发现这种方法对于这样一个简单的任务来说有点太多了。因此我想知道，是否有更好的或者最好的方法是什么，以简洁和可读的方式使用流和函数使这种行为可重用？

这取决于您认为什么“更简洁和可读”。我本人认为您已经实施的方式就很好。

然而，确实有一种方法可以从使用它的地方稍微缩短一点，通过使用Stream.flatMap:

static <E, T> Function<E, Stream<T>> onlyTypes(Class<T> cls) {
  return el -> cls.isInstance(el) ? Stream.of((T) el) : Stream.empty();
}

它所做的是将每个原始流元素转换为Stream一个元素（如果该元素具有预期类型），或者为空Stream如果没有。

其用途是：

records.stream()
  .flatMap(onlyTypes(GroupRecord.class))
  .forEach(...);

这种方法有明显的权衡：

• 您确实从管道定义中丢失了“过滤器”一词。这可能比原来的更令人困惑，所以也许是一个比原来更好的名字onlyTypes是需要的。
• Stream对象相对重量级，创建太多对象可能会导致性能下降。但您不应该相信我在这里所说的话并在重负载下分析这两种变体。

Edit:

由于问题询问的是重用filter and map更笼统地说，我觉得这个答案还可以讨论更多的抽象。因此，要重用一般意义上的过滤器和映射，您需要以下内容：

static <E, R> Function<E, Stream<R>> filterAndMap(Predicate<? super E> filter, Function<? super E, R> mapper) {
   return e -> filter.test(e) ? Stream.of(mapper.apply(e)) : Stream.empty();
}

和原创的onlyTypes实施现在变成：

static <E, R> Function<E, Stream<R>> onlyTypes(Class<T> cls) {
  return filterAndMap(cls::isInstance, cls::cast);
}

但是，再次需要权衡：生成的平面映射器函数现在将保存捕获的两个对象（谓词和映射器），而不是单个对象Class上述实现中的对象。这也可能是过度抽象的情况，但这取决于您需要该代码的位置和原因。