Package | Description |
---|---|
com.hazelcast.mapreduce.impl |
This package contains the default implementation for the map reduce framework
internals.
|
com.hazelcast.mapreduce.impl.task |
This package contains the base implementation for a standard map reduce job.
|
Class and Description |
---|
JobPartitionStateImpl
This class holds information about the current processing state and the owner of a partition
|
JobProcessInformationImpl
This class controls all partition states and is capable of atomically updating those states.
|
JobSupervisor
The JobSupervisor is the overall control instance of a map reduce job.
|
JobTaskConfiguration
This class contains all configuration settings for a given map reduce job.
|
MapCombineTask
This class acutally executed the mapping-combine phase.
|
ReducerTask
This task implementation executes the reducing phase.
|
TrackableJobFuture
This is the node based implementation of the job's reactive
ICompletableFuture
and is returned to the users codebase. |
Class and Description |
---|
DefaultContext
This is the internal default implementation of a map reduce context mappers emit values to.
|
JobProcessInformationImpl
This class controls all partition states and is capable of atomically updating those states.
|
JobSupervisor
The JobSupervisor is the overall control instance of a map reduce job.
|
JobTaskConfiguration
This class contains all configuration settings for a given map reduce job.
|
MapCombineTask
This class acutally executed the mapping-combine phase.
|
MappingPhase
This is the base of all mapping phase implementations.
|
TrackableJobFuture
This is the node based implementation of the job's reactive
ICompletableFuture
and is returned to the users codebase. |
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.