public abstract class AbstractJobTracker extends Object implements JobTracker
JobTracker
implementations on node and client side.Modifier and Type | Field and Description |
---|---|
protected ExecutorService |
executorService |
protected JobTrackerConfig |
jobTrackerConfig |
protected ConcurrentMap<String,MapCombineTask> |
mapCombineTasks |
protected MapReduceService |
mapReduceService |
protected String |
name |
protected NodeEngine |
nodeEngine |
protected ConcurrentMap<String,ReducerTask> |
reducerTasks |
protected ConcurrentMap<String,TrackableJobFuture> |
trackableJobs |
Modifier and Type | Method and Description |
---|---|
void |
destroy()
Destroys this object cluster-wide.
|
JobTrackerConfig |
getJobTrackerConfig() |
<KeyIn,ValueIn,KeyOut,ValueOut,Chunk> |
getMapCombineTask(String jobId) |
String |
getName()
Returns the unique name for this DistributedObject.
|
String |
getPartitionKey()
Returns the key of the partition that this DistributedObject is assigned to.
|
<Key,Chunk> |
getReducerTask(String jobId) |
String |
getServiceName()
Returns the service name for this object.
|
<V> TrackableJobFuture<V> |
getTrackableJob(String jobId)
Returns an implementation of
TrackableJob , or null if the job id is not available
or the job is already finished. |
<KeyIn,ValueIn,KeyOut,ValueOut,Chunk> |
registerMapCombineTask(MapCombineTask<KeyIn,ValueIn,KeyOut,ValueOut,Chunk> mapCombineTask) |
<Key,Chunk> |
registerReducerTask(ReducerTask<Key,Chunk> reducerTask) |
<V> boolean |
registerTrackableJob(TrackableJobFuture<V> trackableJob) |
MapCombineTask |
unregisterMapCombineTask(String jobId) |
ReducerTask |
unregisterReducerTask(String jobId) |
<V> TrackableJobFuture<V> |
unregisterTrackableJob(String jobId) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
newJob
protected final ConcurrentMap<String,TrackableJobFuture> trackableJobs
protected final ConcurrentMap<String,ReducerTask> reducerTasks
protected final ConcurrentMap<String,MapCombineTask> mapCombineTasks
protected final NodeEngine nodeEngine
protected final ExecutorService executorService
protected final MapReduceService mapReduceService
protected final JobTrackerConfig jobTrackerConfig
protected final String name
public void destroy()
DistributedObject
destroy
in interface DistributedObject
public String getPartitionKey()
DistributedObject
IAtomicLong
. For a partitioned data structure like an IMap
,
the returned value will not be null, but otherwise undefined.getPartitionKey
in interface DistributedObject
public final String getName()
DistributedObject
getName
in interface DistributedObject
public final String getServiceName()
DistributedObject
getServiceName
in interface DistributedObject
public JobTrackerConfig getJobTrackerConfig()
public <V> boolean registerTrackableJob(TrackableJobFuture<V> trackableJob)
public <V> TrackableJobFuture<V> unregisterTrackableJob(String jobId)
public <V> TrackableJobFuture<V> getTrackableJob(String jobId)
JobTracker
TrackableJob
, or null if the job id is not available
or the job is already finished.getTrackableJob
in interface JobTracker
V
- type of the resulting valuejobId
- job id to search the TrackableJob forpublic <Key,Chunk> void registerReducerTask(ReducerTask<Key,Chunk> reducerTask)
public ReducerTask unregisterReducerTask(String jobId)
public <Key,Chunk> ReducerTask<Key,Chunk> getReducerTask(String jobId)
public <KeyIn,ValueIn,KeyOut,ValueOut,Chunk> void registerMapCombineTask(MapCombineTask<KeyIn,ValueIn,KeyOut,ValueOut,Chunk> mapCombineTask)
public MapCombineTask unregisterMapCombineTask(String jobId)
public <KeyIn,ValueIn,KeyOut,ValueOut,Chunk> MapCombineTask<KeyIn,ValueIn,KeyOut,ValueOut,Chunk> getMapCombineTask(String jobId)
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.