Package | Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
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() |
Modifier and Type | Method and Description |
---|---|
<ValueOut> ReducingSubmittableJob<EntryKey,KeyIn,ValueOut> |
MappingJob.reducer(ReducerFactory<? super KeyIn,? super ValueIn,? extends ValueOut> reducerFactory)
Defines the
ReducerFactory for this task. |
<ValueOut> ReducingSubmittableJob<EntryKey,KeyIn,ValueOut> |
ReducingJob.reducer(ReducerFactory<KeyIn,ValueIn,ValueOut> reducerFactory)
Defines the
ReducerFactory for this task. |
Modifier and Type | Method and Description |
---|---|
ReducerFactory |
Aggregation.getReducerFactory()
Returns the ReducerFactory for this aggregation.
|
Modifier and Type | Field and Description |
---|---|
protected ReducerFactory<?,?,?> |
AbstractJob.reducerFactory |
Modifier and Type | Method and Description |
---|---|
<ValueOut> ReducingSubmittableJob<EntryKey,Key,ValueOut> |
AbstractJob.MappingJobImpl.reducer(ReducerFactory<? super Key,? super Value,? extends ValueOut> reducerFactory) |
<ValueOut> ReducingSubmittableJob<EntryKey,Key,ValueOut> |
AbstractJob.ReducingJobImpl.reducer(ReducerFactory<Key,Value,ValueOut> reducerFactory) |
Modifier and Type | Field and Description |
---|---|
protected ReducerFactory |
ClientMapReduceRequest.reducerFactory |
Constructor and Description |
---|
ClientMapReduceRequest(String name,
String jobId,
Collection keys,
KeyPredicate predicate,
Mapper mapper,
CombinerFactory combinerFactory,
ReducerFactory reducerFactory,
KeyValueSource keyValueSource,
int chunkSize,
TopologyChangedStrategy topologyChangedStrategy) |
Constructor and Description |
---|
KeyValueJobOperation(String name,
String jobId,
int chunkSize,
KeyValueSource<K,V> keyValueSource,
Mapper mapper,
CombinerFactory combinerFactory,
ReducerFactory reducerFactory,
boolean communicateStats,
TopologyChangedStrategy topologyChangedStrategy) |
Modifier and Type | Method and Description |
---|---|
ReducerFactory |
JobTaskConfiguration.getReducerFactory() |
Constructor and Description |
---|
JobTaskConfiguration(Address jobOwner,
NodeEngine nodeEngine,
int chunkSize,
String name,
String jobId,
Mapper mapper,
CombinerFactory combinerFactory,
ReducerFactory reducerFactory,
KeyValueSource keyValueSource,
boolean communicateStats,
TopologyChangedStrategy topologyChangedStrategy) |
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.