|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ReducerFactory | |
---|---|
com.hazelcast.client.impl.protocol.task.mapreduce | Client protocol tasks implementations for map reduce |
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.aggregation | This package contains the aggregation API and the convenience helper classes to retrieve predefined aggregation implementations. |
com.hazelcast.mapreduce.aggregation.impl | This package contains a set of predefined aggregation implementations |
com.hazelcast.mapreduce.impl | This package contains the default implementation for the map reduce framework internals. |
com.hazelcast.mapreduce.impl.client | This package contains request and response classes for communication between cluster members and Hazelcast native clients |
com.hazelcast.mapreduce.impl.operation | This package contains all remote operations that are needed to control work on supervising or worker nodes. |
com.hazelcast.mapreduce.impl.task | This package contains the base implementation for a standard map reduce job. |
Uses of ReducerFactory in com.hazelcast.client.impl.protocol.task.mapreduce |
---|
Methods in com.hazelcast.client.impl.protocol.task.mapreduce that return ReducerFactory | |
---|---|
protected ReducerFactory |
MapReduceForMapMessageTask.getReducerFactory()
|
protected ReducerFactory |
MapReduceForSetMessageTask.getReducerFactory()
|
protected abstract ReducerFactory |
AbstractMapReduceTask.getReducerFactory()
|
protected ReducerFactory |
MapReduceForCustomMessageTask.getReducerFactory()
|
protected ReducerFactory |
MapReduceForListMessageTask.getReducerFactory()
|
protected ReducerFactory |
MapReduceForMultiMapMessageTask.getReducerFactory()
|
Uses of ReducerFactory in com.hazelcast.mapreduce |
---|
Methods in com.hazelcast.mapreduce with parameters of type ReducerFactory | ||
---|---|---|
|
ReducingJob.reducer(ReducerFactory<KeyIn,ValueIn,ValueOut> reducerFactory)
Defines the ReducerFactory for this task. |
|
|
MappingJob.reducer(ReducerFactory<KeyIn,ValueIn,ValueOut> reducerFactory)
Defines the ReducerFactory for this task. |
Uses of ReducerFactory in com.hazelcast.mapreduce.aggregation |
---|
Methods in com.hazelcast.mapreduce.aggregation that return ReducerFactory | |
---|---|
ReducerFactory |
Aggregation.getReducerFactory()
Returns the ReducerFactory for this aggregation. |
Uses of ReducerFactory in com.hazelcast.mapreduce.aggregation.impl |
---|
Uses of ReducerFactory in com.hazelcast.mapreduce.impl |
---|
Fields in com.hazelcast.mapreduce.impl declared as ReducerFactory | |
---|---|
protected ReducerFactory<?,?,?> |
AbstractJob.reducerFactory
|
Methods in com.hazelcast.mapreduce.impl with parameters of type ReducerFactory | ||
---|---|---|
|
AbstractJob.MappingJobImpl.reducer(ReducerFactory<Key,Value,ValueOut> reducerFactory)
|
|
|
AbstractJob.ReducingJobImpl.reducer(ReducerFactory<Key,Value,ValueOut> reducerFactory)
|
Uses of ReducerFactory in com.hazelcast.mapreduce.impl.client |
---|
Fields in com.hazelcast.mapreduce.impl.client declared as ReducerFactory | |
---|---|
protected ReducerFactory |
ClientMapReduceRequest.reducerFactory
|
Constructors in com.hazelcast.mapreduce.impl.client with parameters of type ReducerFactory | |
---|---|
ClientMapReduceRequest(String name,
String jobId,
Collection keys,
KeyPredicate predicate,
Mapper mapper,
CombinerFactory combinerFactory,
ReducerFactory reducerFactory,
KeyValueSource keyValueSource,
int chunkSize,
TopologyChangedStrategy topologyChangedStrategy)
|
Uses of ReducerFactory in com.hazelcast.mapreduce.impl.operation |
---|
Constructors in com.hazelcast.mapreduce.impl.operation with parameters of type ReducerFactory | |
---|---|
KeyValueJobOperation(String name,
String jobId,
int chunkSize,
KeyValueSource<K,V> keyValueSource,
Mapper mapper,
CombinerFactory combinerFactory,
ReducerFactory reducerFactory,
boolean communicateStats,
TopologyChangedStrategy topologyChangedStrategy)
|
Uses of ReducerFactory in com.hazelcast.mapreduce.impl.task |
---|
Methods in com.hazelcast.mapreduce.impl.task that return ReducerFactory | |
---|---|
ReducerFactory |
JobTaskConfiguration.getReducerFactory()
|
Constructors in com.hazelcast.mapreduce.impl.task with parameters of type ReducerFactory | |
---|---|
JobTaskConfiguration(Address jobOwner,
NodeEngine nodeEngine,
int chunkSize,
String name,
String jobId,
Mapper mapper,
CombinerFactory combinerFactory,
ReducerFactory reducerFactory,
KeyValueSource keyValueSource,
boolean communicateStats,
TopologyChangedStrategy topologyChangedStrategy)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |