| 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  | 
MemberAwareMapReduceNotification
Base class for all notifications based on a member 
 | 
class  | 
ReducingFinishedNotification
This notification class is used to signal the  
JobSupervisor
 owner 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 © 2017 Hazelcast, Inc.. All Rights Reserved.