Java 8 collector для Guava неизменяемый стол

Question

Use case:
Список процессов с помощью метода, который возвращает ImmutableTable типа {R,C,V}. Например, ImmutableTable of {Integer,String,Boolean} process(String item){...}

Соберите результат i.e, объедините все результаты и верните ImmutableTable. Есть ли способ достичь этого?

Текущая реализация (как это было предложено артистический):

Как насчет использования параллельного потока? Существуют ли проблемы параллелизма в приведенном ниже коде? С параллельным потоком я получаю «NullPointerException в индексе 1800» на tableBuilder.build(), но отлично работает с потоком.

ImmutableTable<Integer, String, Boolean> buildData() { 

    // list of 4 AwsS3KeyName 
listToProcess.parallelStream() 

    //Create new instance via Guice dependency injection 
.map(s3KeyName -> ProcessorInstanceProvider.get()  
.fetchAndBuild(s3KeyName)) 
.forEach(tableBuilder::putAll); 

return tableBuilder.build(); } 

Хотя ниже код работает с потоком, а также с параллельным потоком. Но ImmutableBuild терпит неудачу из-за дублирования записи для строки и столбца. Что может быть лучшим способом предотвратить дублирование при слиянии таблиц?

public static <R, C, V> Collector<ImmutableTable<R, C, V>,  
ImmutableTable.Builder<R, C, V>, ImmutableTable<R, C, V>> 
toImmutableTable() 
{ 
return Collector.of(ImmutableTable.Builder::new, 
ImmutableTable.Builder::putAll, (builder1, builder2) -> 
builder1.putAll(builder2.build()), ImmutableTable.Builder::build); } 

Edit: Если есть дубликат записи в ImmutableTable.Builder при объединении различных таблиц, то это не удается,

Пытаясь избежать faluire, поставив ImmutableTables в HashBasedTable

ImmutableTable.copyOf(itemListToProcess.parallelStream() 
      .map(itemString -> 
      ProcessorInstanceProvider.get() 
        .buildImmutableTable(itemString)) 
        .collect(
          Collector.of(
            HashBasedTable::create, 
            HashBasedTable::putAll, 
            (a, b) -> { 
             a.putAll(b); 
             return a; 
            })); 
) 

Но я я получаю исключение во время выполнения "вызвано: java.lang.IllegalAccessError: попытался получить доступ к классу com.google.common.collect.AbstractTable".

Как мы можем использовать HashBasedTable в качестве Аккумулятора для сбора данных ImmutablesTables, поскольку HashBasedTable переопределяет существующую запись последним и не терпит неудачу, если мы попытаемся поместить повторяющуюся запись и вернуть агрегированную неизменяемую таблицу.

Answer 1

Это должно работать:

List<String> list; // given a list of String 

ImmutableTable result = list.parallelStream() 
    .map(processor::process) // converts String to ImmutableTable 
    .collect(ImmutableTable.Builder::new, ImmutableTable.Builder::putAll, 
     (a, b) -> a.putAll(b.build()) 
    .build(); 

Это сокращение поточно.

---

Или используя HashBasedTable в качестве промежуточной структуры данных:

ImmutableTable result = ImmutableTable.copyOf(list.parallelStream() 
    .map(processor::process) // converts String to ImmutableTable 
    .collect(HashBasedTable::create, HashBasedTable::putAll, HashBasedTable::putAll)); 

Answer 2

Вы должны быть в состоянии сделать это путем создания соответствующего Collector, используя Collector.of статический фабричный метод:

ImmutableTable<R, C, V> table = 
    list.stream() 
     .map(processor::process) 
     .collect(
      Collector.of(
       () -> new ImmutableTable.Builder<R, C, V>(), 
       (builder, table1) -> builder.putAll(table1), 
       (builder1, builder2) -> 
        new ImmutableTable.Builder<R, C, V>() 
         .putAll(builder1.build()) 
         .putAll(builder2.build()), 
       ImmutableTable.Builder::build)); 

Answer 3

С Guava 21 вы можете использовать сборщик ImmutableTable.toImmutableTable.

public ImmutableTable<Integer, String, Boolean> processList(List<String> strings) { 
    return strings.stream() 
      .map(this::processText) 
      .flatMap(table -> table.cellSet().stream()) 
      .collect(ImmutableTable.toImmutableTable(
        Table.Cell::getRowKey, 
        Table.Cell::getColumnKey, 
        Table.Cell::getValue, 
        (b1, b2) -> b1 && b2 // You can ommit merge function! 
      )); 
} 

private ImmutableTable<Integer, String, Boolean> processText(String text) { 
    return ImmutableTable.of(); // Whatever 
}