|
||||||||||
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 |