| Package | Description | 
|---|---|
| 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. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
<R> R | 
MapReduceService.processRequest(Address address,
              ProcessingOperation processingOperation)  | 
| Modifier and Type | Class and Description | 
|---|---|
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 © 2017 Hazelcast, Inc.. All Rights Reserved.