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.
|
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<String,MapCombineTask> |
AbstractJobTracker.mapCombineTasks |
Modifier and Type | Method and Description |
---|---|
<KeyIn,ValueIn,KeyOut,ValueOut,Chunk> |
AbstractJobTracker.getMapCombineTask(String jobId) |
MapCombineTask |
AbstractJobTracker.unregisterMapCombineTask(String jobId) |
Modifier and Type | Method and Description |
---|---|
<KeyIn,ValueIn,KeyOut,ValueOut,Chunk> |
AbstractJobTracker.registerMapCombineTask(MapCombineTask<KeyIn,ValueIn,KeyOut,ValueOut,Chunk> mapCombineTask) |
Modifier and Type | Method and Description |
---|---|
<K,V> DefaultContext<K,V> |
JobSupervisor.getOrCreateContext(MapCombineTask mapCombineTask) |
Constructor and Description |
---|
DefaultContext(CombinerFactory<KeyIn,ValueIn,?> combinerFactory,
MapCombineTask mapCombineTask) |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.