|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use MapReduceService | |
|---|---|
| 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 MapReduceService in com.hazelcast.mapreduce.impl |
|---|
| Fields in com.hazelcast.mapreduce.impl declared as MapReduceService | |
|---|---|
protected MapReduceService |
AbstractJobTracker.mapReduceService
|
| Methods in com.hazelcast.mapreduce.impl with parameters of type MapReduceService | ||
|---|---|---|
static void |
MapReduceUtil.enforcePartitionTableWarmup(MapReduceService mapReduceService)
|
|
static
|
MapReduceUtil.executeOperation(Operation operation,
Address address,
MapReduceService mapReduceService,
NodeEngine nodeEngine)
|
|
static
|
MapReduceUtil.executeOperation(OperationFactory operationFactory,
MapReduceService mapReduceService,
NodeEngine nodeEngine,
boolean returnsResponse)
|
|
| Uses of MapReduceService in com.hazelcast.mapreduce.impl.task |
|---|
| Methods in com.hazelcast.mapreduce.impl.task that return MapReduceService | |
|---|---|
MapReduceService |
JobSupervisor.getMapReduceService()
|
| Constructors in com.hazelcast.mapreduce.impl.task with parameters of type MapReduceService | |
|---|---|
JobSupervisor(JobTaskConfiguration configuration,
AbstractJobTracker jobTracker,
boolean ownerNode,
MapReduceService mapReduceService)
|
|
KeyValueJob(String name,
AbstractJobTracker jobTracker,
NodeEngine nodeEngine,
MapReduceService mapReduceService,
KeyValueSource<KeyIn,ValueIn> keyValueSource)
|
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||