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 © 2021 Hazelcast, Inc.. All Rights Reserved.