public class JobSupervisor extends Object
TopologyChangedStrategy
in case of a topology change situation.Constructor and Description |
---|
JobSupervisor(JobTaskConfiguration configuration,
AbstractJobTracker jobTracker,
boolean ownerNode,
MapReduceService mapReduceService) |
public JobSupervisor(JobTaskConfiguration configuration, AbstractJobTracker jobTracker, boolean ownerNode, MapReduceService mapReduceService)
public MapReduceService getMapReduceService()
public JobTracker getJobTracker()
public void startTasks(MappingPhase mappingPhase)
public void onNotification(MapReduceNotification notification)
public boolean cancelAndNotify(Exception exception)
public TrackableJobFuture cancel()
public <KeyIn,ValueIn,ValueOut> Reducer<ValueIn,ValueOut> getReducerByKey(Object key)
public boolean checkAssignedMembersAvailable()
public void checkFullyProcessed(JobProcessInformation processInformation)
public <K,V> DefaultContext<K,V> getOrCreateContext(MapCombineTask mapCombineTask)
public void registerReducerEventInterests(int partitionId, Set<Address> remoteReducers)
public Collection<Address> getReducerEventInterests(int partitionId)
public JobProcessInformationImpl getJobProcessInformation()
public Address getJobOwner()
public boolean isOwnerNode()
public JobTaskConfiguration getConfiguration()
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.