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