@Beta public interface JobTracker extends DistributedObject
The JobTracker interface is used to create instances of
on the given data structure / data source.
The default usage is same for both cases and looks similar to the following example:
HazelcastInstance hz = getHazelcastInstance(); IMap map = hz.getMap( getMapName() ); JobTracker tracker = hz.getJobTracker( "default" ); Job job = tracker.newJob( KeyValueSource.fromMap( map ) );
The created instance of JobTracker is fully threadsafe and can be used concurrently and multiple times.
Caution: Do not use the JobTracker with data structures of other
instances than the one used for creation of the JobTracker. Unexpected results may happen!
|Modifier and Type||Method and Description|
Returns an implementation of
<K,V> Job<K,V> newJob(KeyValueSource<K,V> source)
Jobinstance for the given
KeyValueSourceinstance. The returning implementation depends on the
HazelcastInstancethat created the JobTracker.
HazelcastInstanceinstances than the one used for creation of the JobTracker. Unexpected results may happen!
K- type of the key
V- type of the value
source- data source the created Job should work on
<V> TrackableJob<V> getTrackableJob(String jobId)
TrackableJob, or null if the job id is not available or the job is already finished.
V- type of the resulting value
jobId- job id to search the TrackableJob for
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.