Uses of Class
com.hazelcast.mapreduce.impl.operation.ProcessingOperation

Packages that use ProcessingOperation

com.hazelcast.mapreduce.impl	This package contains the default implementation for the map reduce framework internals.
com.hazelcast.mapreduce.impl.operation	This package contains all remote operations that are needed to control work on supervising or worker nodes.

Uses of ProcessingOperation in com.hazelcast.mapreduce.impl

Methods in com.hazelcast.mapreduce.impl with parameters of type ProcessingOperation

<R> R

MapReduceService.processRequest(Address address, ProcessingOperation processingOperation)

Uses of ProcessingOperation in com.hazelcast.mapreduce.impl.operation

Subclasses of ProcessingOperation in com.hazelcast.mapreduce.impl.operation

class	CancelJobSupervisorOperation This operation is fired by the jobs owner node to remotely cancel the defined jobId on all nodes.
class	FireNotificationOperation This operation is used to transport and execute a notification on a remote node since the current event service is not capable of reliable transmission so this is a fallback to sync operations which is hopefully only a temporary workaround!
class	GetResultOperation This operation is used to retrieve results from a remote node
class	KeysAssignmentOperation This operation is used to request assignment for keys on the job owners node.
class	NotifyRemoteExceptionOperation This operation is used to inform the job owner of a remote exception
class	PostPonePartitionProcessing This operation is used to tell the job owner to postpone a mapping phase for the defined partitionId.
class	ProcessStatsUpdateOperation This operation is used to update the process statistics on the owner node
class	RequestMemberIdAssignment This operation is used to do some kind of partitionId based processing on non partition based implementations of KeyValueSource (not implementing PartitionIdAware) which can happen for custom data sources like distributed filesystems that are up to the end user on how to manage the distribution.
class	RequestPartitionMapping This operation requests a new partition to process by the requester on the job owning node
class	RequestPartitionProcessed This operation tells the job owner to mark a partition as fully processed
class	RequestPartitionReducing This operation tells the job owner to start reducing phase of the defined partition on the first occurrence of a full emitted chunk