public final class MapReduceUtil extends Object
Modifier and Type | Method and Description |
---|---|
static String |
buildExecutorName(String name) |
static JobProcessInformationImpl |
createJobProcessInformation(JobTaskConfiguration configuration,
JobSupervisor supervisor) |
static void |
enforcePartitionTableWarmup(MapReduceService mapReduceService) |
static <V> List<V> |
executeOperation(Collection<Member> members,
OperationFactory operationFactory,
MapReduceService mapReduceService,
NodeEngine nodeEngine) |
static <V> V |
executeOperation(Operation operation,
Address address,
MapReduceService mapReduceService,
NodeEngine nodeEngine) |
static int |
mapSize(int sourceSize) |
static void |
notifyRemoteException(JobSupervisor supervisor,
Throwable throwable) |
static JobPartitionState.State |
stateChange(Address owner,
int partitionId,
JobPartitionState.State currentState,
JobProcessInformationImpl processInformation,
JobTaskConfiguration configuration) |
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 <V> List<V> executeOperation(Collection<Member> members, OperationFactory operationFactory, MapReduceService mapReduceService, NodeEngine nodeEngine)
public static <V> V executeOperation(Operation operation, Address address, MapReduceService mapReduceService, NodeEngine nodeEngine)
public static int mapSize(int sourceSize)
public static void enforcePartitionTableWarmup(MapReduceService mapReduceService) throws TimeoutException
TimeoutException
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.