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 CombinerFactory |
MapReduceForMapMessageTask.getCombinerFactory() |
protected CombinerFactory |
MapReduceForSetMessageTask.getCombinerFactory() |
protected abstract CombinerFactory |
AbstractMapReduceTask.getCombinerFactory() |
protected CombinerFactory |
MapReduceForCustomMessageTask.getCombinerFactory() |
protected CombinerFactory |
MapReduceForListMessageTask.getCombinerFactory() |
protected CombinerFactory |
MapReduceForMultiMapMessageTask.getCombinerFactory() |
Modifier and Type | Method and Description |
---|---|
<ValueOut> ReducingJob<EntryKey,KeyIn,ValueOut> |
MappingJob.combiner(CombinerFactory<? super KeyIn,? super ValueIn,? extends ValueOut> combinerFactory)
Defines the
CombinerFactory for this task. |
Modifier and Type | Method and Description |
---|---|
CombinerFactory |
Aggregation.getCombinerFactory()
Returns the CombinerFactory for this aggregation to pre-reduce values on mapping
nodes.
|
Modifier and Type | Field and Description |
---|---|
protected CombinerFactory<?,?,?> |
AbstractJob.combinerFactory |
Modifier and Type | Method and Description |
---|---|
<ValueOut> ReducingJob<EntryKey,Key,ValueOut> |
AbstractJob.MappingJobImpl.combiner(CombinerFactory<? super Key,? super Value,? extends ValueOut> combinerFactory) |
Modifier and Type | Field and Description |
---|---|
protected CombinerFactory |
ClientMapReduceRequest.combinerFactory |
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 |
---|---|
CombinerFactory |
JobTaskConfiguration.getCombinerFactory() |
Constructor and Description |
---|
DefaultContext(CombinerFactory<KeyIn,ValueIn,?> combinerFactory,
MapCombineTask mapCombineTask) |
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.