通过 Java 8 并行流过滤 Guava 的 ImmutableTable

Question

在通过并行流和收集器过滤 Guava 的 ImmutableTable 时需要帮助

过滤表不可变；

用例：遍历 toFilter 并删除 validEntry 表中不存在或条目值为 false 的元素。 通过 for 循环执行此操作的传统方式：

  ImmutableTable<MarketplaceArc, String, ObjectB> filterInactive(final ImmutableTable<MarketplaceArc, String, ObjectB> toFilter) {

     final ImmutableTable.Builder filteredResultBuilder =
            ImmutableTable.builder();

     final Map<MarketplaceArc, Map<String, ObjectB>> rowMap = 
     browseMappings.rowMap();

     for (final Map.Entry<MarketplaceArc, Map<String, ObjectB>> 
      rowMapEntry : rowMap.entrySet()) {

        for (final Map.Entry<String, ObjectB> entry : 
           rowMapEntry.getValue().entrySet()) {

           if(ifActive(rowMap.getKey, entry)){
            filteredResultBuilder.put(
                    rowMapEntry.getKey(),
                    entry.getKey(),
                    buildObjectB(entry));
               }
        }
    }
    return filteredResultBuilder.build();
}

有没有更好更简洁的方法通过 Java parallelStreams 做到这一点？

Answer 1

是的，你可以做得更好。您可以使用Table.Cell 之一。这样，您可以将两个循环减少为一个。您甚至可以通过使用谓词使您的方法更通用。

我知道您写过您的应用程序适用于 Java 8，但使用 Java 8 流和类似的酷东西根本不可能这样做，因为到目前为止，Table 并不是为 Java 8 设计的（无法从 Cells 的 Itera{ble,tor} 构建表；表不需要 BiPredicate 但 TriPredicate）。因此，让我们改进您的代码，简单而基本。

简单的旧循环，针对Tables 进行了优化

所以这是基本版本。没有什么特别的，但比您的方式做得更好，因为它不依赖中间复杂的数据结构（例如，您继续使用地图，这个解决方案没有）。

ImmutableTable<MarketplaceArc, String, ObjectB> filterInactive(Table<MarketplaceArc, String, ObjectB> unfiltered) {
  ImmutableTable.Builder<MarketplaceArc, String, ObjectB> filtered = ImmutableTable.builder();
  for (Table.Cell<MarketplaceArc, String, ObjectB> cell: unfiltered.cells()) {
    if (isActive(cell.getRow(), cell.getValue())) {
      filtered.put(cell);
    }
  }
  return filtered.build();
}

带有谓词的通用解决方案

更通用的解决方案是使用通用过滤方法。多亏了一些 Java 8 的魔法，这将使您的代码更具可读性：

// Generic method.
<R,C,V> ImmutableTable<R,C,V> filterToImmutable(Table<R,C,V> unfiltered, Predicate<Table.Cell<R,C,V>> predicate) {
  ImmutableTable.Builder<R,C,V> filtered = ImmutableTable.builder();

  // Actually, let's use some Java 8, just because we can!
  unfiltered.cells().parallelStream()
      .filter(predicate)
      .foreach(filtered::put);
  return filtered.build();
}

// Specific predicate
boolean isActiveCell(Table.Cell<MarketplaceArc, String, ObjectB> cell) {
  return isActive(cell.getRow(), cell.getValue());
}

// Use all you've written, with some Java 8, just because we can. Again.
ImmutableTable<MarketplaceArc, Map<String, ObjectB> unfiltered = ... ;
ImmutableTable<MarketplaceArc, Map<String, ObjectB> filtered = filterToImmutable(unfiltered, this::isActiveCell);