com.hazelcast.mapreduce.impl

Class MapReduceUtil

java.lang.Object

com.hazelcast.mapreduce.impl.MapReduceUtil

public final class MapReduceUtil
extends Object

This utility class contains a few basic operations that are needed in multiple places

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

createJobProcessInformation

public static JobProcessInformationImpl createJobProcessInformation(JobTaskConfiguration configuration,
                                                                    JobSupervisor supervisor)

notifyRemoteException

public static void notifyRemoteException(JobSupervisor supervisor,
                                         Throwable throwable)

stateChange

public static JobPartitionState.State stateChange(Address owner,
                                                  int partitionId,
                                                  JobPartitionState.State currentState,
                                                  JobProcessInformationImpl processInformation,
                                                  JobTaskConfiguration configuration)

executeOperation

public static <V> List<V> executeOperation(Collection<Member> members,
                                           OperationFactory operationFactory,
                                           MapReduceService mapReduceService,
                                           NodeEngine nodeEngine)

executeOperation

public static <V> V executeOperation(Operation operation,
                                     Address address,
                                     MapReduceService mapReduceService,
                                     NodeEngine nodeEngine)

buildExecutorName

public static String buildExecutorName(String name)

mapSize

public static int mapSize(int sourceSize)

enforcePartitionTableWarmup

public static void enforcePartitionTableWarmup(MapReduceService mapReduceService)
                                        throws TimeoutException

Throws:

TimeoutException