HazelcastAPI MapProxySupport Sınıfı - Proxy implementation of IMap

Giriş

Şu satırı dahil ederiz

import com.hazelcast.map.impl.proxy.MapProxysupport;

Bu sınıfı içinde şöyle bir alan var.

OperationService operationService;

Bu nesne ile tüm cluster üyelerine bir sorgu gönderip cevabı toplanabiliyor. 

public void executeOnEntriesInternal(EntryProcessor entryProcessor, 
  Predicate predicate, List<Data> result) {

  try {
    Map<Integer, Object> results;
    if (predicate instanceof PartitionPredicate) {
      ....
      OperationFactory operation = operationProvider
        .createPartitionWideEntryWithPredicateOperationFactory();
      results = operationService.invokeOnPartitions(...)
      );
    } else {
        OperationFactory operation = operationProvider
          .createPartitionWideEntryWithPredicateOperationFactory();
        results = operationService.invokeOnAllPartitions(SERVICE_NAME, operation);
    }
    ...  
  } catch (Throwable t) {
    throw rethrow(t);
  }
}