HazelcastAPI Aggregators Sınıfı - Kullanmayın

Giriş

IMap 3 tane metod sunuyor. Bunlar şöyle

accumulate()
combine()
aggregate()

Sanırım Predicate API artık idame (maintenance) durumda, ve bunun yerine SQL API'nin kullanılması daha iyi.

aggregate metodu

İmzası şöyle

<R> R aggregate(Aggregator<Map.Entry<K, V>, R> aggregator, Predicate<K, V> predicate);

Aggregator Sınıfı

Şu satırı dahil ederiz

import com.hazelcast.aggregation.Aggregators;

Aggregators sınıf hazır bazı aggregator metodları sunuyor. Bunlar şöyle

count

distinct

bigDecimal sum/avg/min/max

bigInteger sum/avg/min/max

double sum/avg/min/max

integer sum/avg/min/max

long sum/avg/min/max

number avg

comparable min/max

fixedPointSum, floatingPointSum

count metodu

Örnek

Şöyle yaparız

HazelcastInstance hazelCast = Hazelcast.newHazelcastInstance();
IMap<String, String> map1 = hazelCast.getMap("map1");

map1.put("1", "john");
map1.put("2", "charlie");   
map1.put("3", "john");
map1.put("4", "john");
    
Long count = map1.aggregate(Aggregators.count(), e -> "john".equals(e.getValue()));

System.out.println(count);