Package | Description |
---|---|
com.hazelcast.client.impl |
Contains most of the client side HazelcastInstance implementation functionality.
|
com.hazelcast.client.proxy |
This package contains client side proxy implementations of the different Hazelcast data structures
and operation types
|
com.hazelcast.core |
Provides core API interfaces/classes.
|
com.hazelcast.instance |
This package contains Hazelcast Instance functionality.
|
com.hazelcast.map.impl.proxy |
Contains map proxy implementation and support classes.
|
com.hazelcast.mapreduce |
This package contains the MapReduce API definition for Hazelcast.
All map reduce operations running in a distributed manner inside the active Hazelcast cluster. |
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.
|
com.hazelcast.multimap.impl |
Contains classes for Hazelcast MultiMap module.
|
Modifier and Type | Method and Description |
---|---|
JobTracker |
HazelcastClientInstanceImpl.getJobTracker(String name) |
JobTracker |
HazelcastClientProxy.getJobTracker(String name) |
Modifier and Type | Class and Description |
---|---|
class |
ClientMapReduceProxy
Proxy implementation of
JobTracker for a client initiated map reduce job. |
Modifier and Type | Method and Description |
---|---|
<SuppliedValue,Result> |
ClientMapProxy.aggregate(Supplier<K,V,SuppliedValue> supplier,
Aggregation<K,SuppliedValue,Result> aggregation,
JobTracker jobTracker) |
<SuppliedValue,Result> |
ClientMultiMapProxy.aggregate(Supplier<K,V,SuppliedValue> supplier,
Aggregation<K,SuppliedValue,Result> aggregation,
JobTracker jobTracker) |
Modifier and Type | Method and Description |
---|---|
JobTracker |
HazelcastInstance.getJobTracker(String name)
Returns the job tracker instance with the specified name.
|
Modifier and Type | Method and Description |
---|---|
<SuppliedValue,Result> |
IMap.aggregate(Supplier<K,V,SuppliedValue> supplier,
Aggregation<K,SuppliedValue,Result> aggregation,
JobTracker jobTracker)
Executes a predefined aggregation on the maps data set.
|
<SuppliedValue,Result> |
MultiMap.aggregate(Supplier<K,V,SuppliedValue> supplier,
Aggregation<K,SuppliedValue,Result> aggregation,
JobTracker jobTracker)
Executes a predefined aggregation on the multimaps data set.
|
Modifier and Type | Method and Description |
---|---|
JobTracker |
HazelcastInstanceImpl.getJobTracker(String name) |
JobTracker |
HazelcastInstanceProxy.getJobTracker(String name) |
Modifier and Type | Method and Description |
---|---|
<SuppliedValue,Result> |
MapProxyImpl.aggregate(Supplier<K,V,SuppliedValue> supplier,
Aggregation<K,SuppliedValue,Result> aggregation,
JobTracker jobTracker) |
Modifier and Type | Method and Description |
---|---|
JobTracker |
TrackableJob.getJobTracker()
Returns the assigned
JobTracker |
Modifier and Type | Class and Description |
---|---|
class |
AbstractJobTracker
This is the base class for all
JobTracker implementations on node and client side.It combines a lot of the base functionality to handle remote operations. |
Modifier and Type | Field and Description |
---|---|
protected JobTracker |
AbstractJob.jobTracker |
Modifier and Type | Method and Description |
---|---|
JobTracker |
MapReduceService.getJobTracker(String name) |
Constructor and Description |
---|
AbstractJob(String name,
JobTracker jobTracker,
KeyValueSource<KeyIn,ValueIn> keyValueSource) |
Modifier and Type | Method and Description |
---|---|
JobTracker |
TrackableJobFuture.getJobTracker() |
JobTracker |
JobSupervisor.getJobTracker() |
Constructor and Description |
---|
TrackableJobFuture(String name,
String jobId,
JobTracker jobTracker,
NodeEngine nodeEngine,
Collator collator) |
Modifier and Type | Method and Description |
---|---|
<SuppliedValue,Result> |
ObjectMultiMapProxy.aggregate(Supplier<K,V,SuppliedValue> supplier,
Aggregation<K,SuppliedValue,Result> aggregation,
JobTracker jobTracker) |
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.