|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use com.hazelcast.mapreduce.impl.task | |
---|---|
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. |
Classes in com.hazelcast.mapreduce.impl.task used by com.hazelcast.mapreduce.impl | |
---|---|
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. |
Classes in com.hazelcast.mapreduce.impl.task used by com.hazelcast.mapreduce.impl.task | |
---|---|
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. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |