public final class MapReduceUtil extends Object
public static JobProcessInformationImpl createJobProcessInformation(JobTaskConfiguration configuration, JobSupervisor supervisor)
public static void notifyRemoteException(JobSupervisor supervisor, Throwable throwable)
public static JobPartitionState.State stateChange(Address owner, int partitionId, JobPartitionState.State currentState, JobProcessInformationImpl processInformation, JobTaskConfiguration configuration)
public static <K,V> Map<Address,Map<K,V>> mapResultToMember(JobSupervisor supervisor, Map<K,V> result)
public static String printPartitionStates(JobPartitionState[] partitionStates)
public static <V> List<V> executeOperation(OperationFactory operationFactory, MapReduceService mapReduceService, NodeEngine nodeEngine, boolean returnsResponse)
public static <V> V executeOperation(Operation operation, Address address, MapReduceService mapReduceService, NodeEngine nodeEngine)
public static int mapSize(int sourceSize)
public static void injectManagedContext(NodeEngine nodeEngine, Object injectee, Object... injectees)
Copyright © 2014 Hazelcast, Inc.. All rights reserved.