| 
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use MapReduceNotification | |
|---|---|
| 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. | 
| Uses of MapReduceNotification in com.hazelcast.mapreduce.impl | 
|---|
| Methods in com.hazelcast.mapreduce.impl with parameters of type MapReduceNotification | |
|---|---|
 void | 
MapReduceService.dispatchEvent(MapReduceNotification notification)
 | 
 void | 
MapReduceService.sendNotification(Address address,
                 MapReduceNotification notification)
 | 
| Uses of MapReduceNotification in com.hazelcast.mapreduce.impl.notification | 
|---|
| Subclasses of MapReduceNotification in com.hazelcast.mapreduce.impl.notification | |
|---|---|
 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. | 
| Uses of MapReduceNotification in com.hazelcast.mapreduce.impl.operation | 
|---|
| Constructors in com.hazelcast.mapreduce.impl.operation with parameters of type MapReduceNotification | |
|---|---|
FireNotificationOperation(MapReduceNotification notification)
 | 
|
| Uses of MapReduceNotification in com.hazelcast.mapreduce.impl.task | 
|---|
| Methods in com.hazelcast.mapreduce.impl.task with parameters of type MapReduceNotification | |
|---|---|
 void | 
JobSupervisor.onNotification(MapReduceNotification notification)
 | 
  | 
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||