|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use MapCombineTask | |
---|---|
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. |
Uses of MapCombineTask in com.hazelcast.mapreduce.impl |
---|
Fields in com.hazelcast.mapreduce.impl with type parameters of type MapCombineTask | |
---|---|
protected ConcurrentMap<String,MapCombineTask> |
AbstractJobTracker.mapCombineTasks
|
Methods in com.hazelcast.mapreduce.impl that return MapCombineTask | ||
---|---|---|
|
AbstractJobTracker.getMapCombineTask(String jobId)
|
|
MapCombineTask |
AbstractJobTracker.unregisterMapCombineTask(String jobId)
|
Methods in com.hazelcast.mapreduce.impl with parameters of type MapCombineTask | ||
---|---|---|
|
AbstractJobTracker.registerMapCombineTask(MapCombineTask<KeyIn,ValueIn,KeyOut,ValueOut,Chunk> mapCombineTask)
|
Uses of MapCombineTask in com.hazelcast.mapreduce.impl.task |
---|
Methods in com.hazelcast.mapreduce.impl.task with parameters of type MapCombineTask | ||
---|---|---|
|
JobSupervisor.getOrCreateContext(MapCombineTask mapCombineTask)
|
Constructors in com.hazelcast.mapreduce.impl.task with parameters of type MapCombineTask | |
---|---|
DefaultContext(CombinerFactory<KeyIn,ValueIn,?> combinerFactory,
MapCombineTask mapCombineTask)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |