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