java – 如何重用应用程序的过滤器和地图在流？

我有一组继承自共享类型的域对象(即GroupRecord扩展Record,RequestRecord extends Record).子类型具有特定属性(即GroupRecord :: getCumulativeTime,RequestRecord :: getResponseTime).

此外,由于解析日志文件,我有一个具有混合子类型的记录列表.

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

为了计算日志记录的统计信息,我想仅在与特定子类型匹配的记录子集(即仅在GroupRecords上)应用数学函数.因此,我想要一个过滤的特定子类型的流.我知道我可以应用过滤器并映射到子类型

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

在流上多次应用此过滤器& cast(特别是对于不同的计算对于相同的子类型进行多次)不仅麻烦,而且产生大量的重复.

我目前的做法是使用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(...)

它有效,但我发现这种方法有点像这么简单的任务.因此,我想知道,使用流和功能以简明易懂的方式使这种行为可以重用吗最好的方法是什么？

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

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

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();
}

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