|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use JobSupervisor | |
---|---|
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 JobSupervisor in com.hazelcast.mapreduce.impl |
---|
Methods in com.hazelcast.mapreduce.impl that return JobSupervisor | |
---|---|
JobSupervisor |
MapReduceService.createJobSupervisor(JobTaskConfiguration configuration)
|
JobSupervisor |
MapReduceService.getJobSupervisor(String name,
String jobId)
|
Methods in com.hazelcast.mapreduce.impl with parameters of type JobSupervisor | ||
---|---|---|
static JobProcessInformationImpl |
MapReduceUtil.createJobProcessInformation(JobTaskConfiguration configuration,
JobSupervisor supervisor)
|
|
boolean |
MapReduceService.destroyJobSupervisor(JobSupervisor supervisor)
|
|
static
|
MapReduceUtil.mapResultToMember(JobSupervisor supervisor,
Map<K,V> result)
|
|
static void |
MapReduceUtil.notifyRemoteException(JobSupervisor supervisor,
Throwable throwable)
|
Uses of JobSupervisor in com.hazelcast.mapreduce.impl.task |
---|
Constructors in com.hazelcast.mapreduce.impl.task with parameters of type JobSupervisor | |
---|---|
JobProcessInformationImpl(int partitionCount,
JobSupervisor supervisor)
|
|
MapCombineTask(JobTaskConfiguration configuration,
JobSupervisor supervisor,
MappingPhase<KeyIn,ValueIn,KeyOut,ValueOut> mappingPhase)
|
|
MemberAssigningJobProcessInformationImpl(int partitionCount,
JobSupervisor supervisor)
|
|
ReducerTask(String name,
String jobId,
JobSupervisor supervisor)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |