Uses of Class
com.hazelcast.mapreduce.impl.task.JobSupervisor

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
<K,V> Map<Address,Map<K,V>>
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)
           
 



Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.