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
 



Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.