|
||||||||||
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 |