| Package | Description | 
|---|---|
| com.hazelcast.mapreduce.impl | This package contains the default implementation for the map reduce framework
 internals. | 
| com.hazelcast.mapreduce.impl.notification | This package contains all remote node notifications | 
| com.hazelcast.mapreduce.impl.operation | This package contains all remote operations that are needed to control work on
 supervising or worker nodes. | 
| com.hazelcast.mapreduce.impl.task | This package contains the base implementation for a standard map reduce job. | 
| Modifier and Type | Method and Description | 
|---|---|
| void | MapReduceService. dispatchEvent(MapReduceNotification notification) | 
| void | MapReduceService. sendNotification(Address address,
                MapReduceNotification notification) | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | IntermediateChunkNotification<KeyOut,Value>Notification that is fired every time the chunk limit is reached and is send to the reducers | 
| class  | LastChunkNotification<KeyOut,Value>This notification is used to notify the reducer that this chunk is the last chunk of the
 defined partitionId. | 
| class  | MemberAwareMapReduceNotificationBase class for all notifications based on a member | 
| class  | ReducingFinishedNotificationThis notification class is used to signal the  JobSupervisorowner node that a reducer has finished the reducing step for the defined partitionId. | 
| Constructor and Description | 
|---|
| FireNotificationOperation(MapReduceNotification notification) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | JobSupervisor. onNotification(MapReduceNotification notification) | 
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.