public class ClientMapReduceProxy extends ClientProxy implements JobTracker
name
Constructor and Description |
---|
ClientMapReduceProxy(String serviceName,
String objectName) |
Modifier and Type | Method and Description |
---|---|
<V> TrackableJob<V> |
getTrackableJob(String jobId)
Returns an implementation of
TrackableJob , or null if the job id is not available
or the job is already finished. |
<K,V> Job<K,V> |
newJob(KeyValueSource<K,V> source)
Builds a
Job instance for the given KeyValueSource instance. |
protected void |
onDestroy()
Called before proxy is destroyed.
|
String |
toString() |
deregisterListener, destroy, equals, getClient, getContext, getId, getName, getPartitionKey, getServiceName, hashCode, invoke, invoke, invokeOnPartition, invokeOnPartitionInterruptibly, onInitialize, onShutdown, registerListener, setContext, throwExceptionIfNull, toData, toObject
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
destroy, getName, getPartitionKey, getServiceName
protected void onDestroy()
ClientProxy
onDestroy
in class ClientProxy
public <K,V> Job<K,V> newJob(KeyValueSource<K,V> source)
JobTracker
Job
instance for the given KeyValueSource
instance. The returning
implementation depends on the HazelcastInstance
that created
the JobTracker.HazelcastInstance
instances than the one used for creation of the
JobTracker. Unexpected results may happen!newJob
in interface JobTracker
K
- type of the keyV
- type of the valuesource
- data source the created Job should work onpublic <V> TrackableJob<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 forCopyright © 2016 Hazelcast, Inc.. All Rights Reserved.