Параллельное вычисление по набору данных в java 8?

Question

У меня есть набор данных, как это:

Set<CustomObject> testSet = [{id: a1, qty: 3}, 
          {id: a2, qty: 9}, 
          {id: a3, qty: 5}, 
          {id: a4, qty: 8}, 
          {id: a5, qty: 12}, 
          ... 
          {id: a200, qty: 7}]; 

Идентификаторы сгруппированы в 3 группы, которые могут быть найдены с помощью метода:

//The getGroup method is implemented in the class CustomObject. 
//I am using hazelcast map to store few id's that are inclusive, and 
//one of the id that is in the request of the api is the current id. 
public String getGroup(String id){ 
    HazelcastInstance hazelcastInstance = Hazelcast.newHazelcastInstance(); 
    if(id.equals(this.id)){ 
     return "currentId"; 
    }else if(id.equals(hazelcastInstance.getMap("idMap").get(id))){ 
     return "inclusive"; 
    } else { 
     return "exclusive"; 
    } 
} 

testSet выше является с огромными данными, и я хотите выполнить сумму величин каждого объекта в наборе на основе метода группирования выше, используя Java.

Я попытался использовать потоки, но это не позволяет мне использовать метод getGroup в методе groupingBy Java 8 Streams.

Просьба проинструктировать меня о том, как эффективно суммировать значения qty на основе групп с параллельной обработкой.

Answer 1

Вот код, включающий в себя включительно и эксклюзивную сумму.

Map<Object, Integer> resultMap = 
       testSet.stream().parallel() 
       .collect(Collectors.groupingBy(item -> { 
            if(item.getId().equals(hazelcastInstance.getMap("idMap").get(id)) 
             return "inclusive"; 
            else 
             return "exclusive"; 
            }, 
            Collectors.summingInt(CustomObject::getQty))); 

Кроме того, для повышения производительности используйте ArrayList вместо HashSet при использовании параллельных потоков и измерьте его.