Uses of Interface
com.hazelcast.mapreduce.CombinerFactory

Packages that use CombinerFactory

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.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 CombinerFactory in com.hazelcast.client.impl.protocol.task.mapreduce

Methods in com.hazelcast.client.impl.protocol.task.mapreduce that return CombinerFactory

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()

Uses of CombinerFactory in com.hazelcast.mapreduce

Methods in com.hazelcast.mapreduce with parameters of type CombinerFactory

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.

Uses of CombinerFactory in com.hazelcast.mapreduce.aggregation

Methods in com.hazelcast.mapreduce.aggregation that return CombinerFactory

Modifier and Type	Method and Description
CombinerFactory	Aggregation.getCombinerFactory() Returns the CombinerFactory for this aggregation to pre-reduce values on mapping nodes.

Uses of CombinerFactory in com.hazelcast.mapreduce.aggregation.impl

Methods in com.hazelcast.mapreduce.aggregation.impl that return CombinerFactory

Modifier and Type	Method and Description
CombinerFactory<Key,Long,Long>	LongMinAggregation.getCombinerFactory()
CombinerFactory<Key,BigInteger,AvgTuple<Long,BigInteger>>	BigIntegerAvgAggregation.getCombinerFactory()
CombinerFactory<Key,BigDecimal,BigDecimal>	BigDecimalSumAggregation.getCombinerFactory()
CombinerFactory<Key,Long,Long>	LongMaxAggregation.getCombinerFactory()
CombinerFactory<Key,BigInteger,BigInteger>	BigIntegerSumAggregation.getCombinerFactory()
CombinerFactory<Key,BigDecimal,BigDecimal>	BigDecimalMaxAggregation.getCombinerFactory()
CombinerFactory<Key,Comparable,Comparable>	ComparableMinAggregation.getCombinerFactory()
CombinerFactory<Key,Integer,Integer>	IntegerMinAggregation.getCombinerFactory()
CombinerFactory<Key,Comparable,Comparable>	ComparableMaxAggregation.getCombinerFactory()
CombinerFactory<Key,Integer,AvgTuple<Integer,Integer>>	IntegerAvgAggregation.getCombinerFactory()
CombinerFactory<Key,Long,Long>	LongSumAggregation.getCombinerFactory()
CombinerFactory<Key,Long,AvgTuple<Long,Long>>	LongAvgAggregation.getCombinerFactory()
CombinerFactory<Key,Double,AvgTuple<Long,Double>>	DoubleAvgAggregation.getCombinerFactory()
CombinerFactory<Key,Double,Double>	DoubleSumAggregation.getCombinerFactory()
CombinerFactory<Key,Integer,Integer>	IntegerSumAggregation.getCombinerFactory()
CombinerFactory<Key,Integer,Integer>	IntegerMaxAggregation.getCombinerFactory()
CombinerFactory<KeyOut,SuppliedValue,CombinerValue>	AggType.getCombinerFactory()
CombinerFactory<Key,Double,Double>	DoubleMinAggregation.getCombinerFactory()
CombinerFactory<Key,Double,Double>	DoubleMaxAggregation.getCombinerFactory()
CombinerFactory<Key,BigInteger,BigInteger>	BigIntegerMinAggregation.getCombinerFactory()
CombinerFactory<Integer,DistinctType,Set<DistinctType>>	DistinctValuesAggregation.getCombinerFactory()
CombinerFactory<Key,BigInteger,BigInteger>	BigIntegerMaxAggregation.getCombinerFactory()
CombinerFactory<Key,BigDecimal,BigDecimal>	BigDecimalMinAggregation.getCombinerFactory()
CombinerFactory<Key,BigDecimal,AvgTuple<Long,BigDecimal>>	BigDecimalAvgAggregation.getCombinerFactory()
CombinerFactory<Key,Object,Long>	CountAggregation.getCombinerFactory()

Uses of CombinerFactory in com.hazelcast.mapreduce.impl

Fields in com.hazelcast.mapreduce.impl declared as CombinerFactory

Modifier and Type	Field and Description
protected CombinerFactory<?,?,?>	AbstractJob.combinerFactory

Methods in com.hazelcast.mapreduce.impl with parameters of type CombinerFactory

Modifier and Type	Method and Description
<ValueOut> ReducingJob<EntryKey,Key,ValueOut>	AbstractJob.MappingJobImpl.combiner(CombinerFactory<? super Key,? super Value,? extends ValueOut> combinerFactory)

Uses of CombinerFactory in com.hazelcast.mapreduce.impl.operation

Constructors in com.hazelcast.mapreduce.impl.operation with parameters of type CombinerFactory

Constructor and Description
KeyValueJobOperation(String name, String jobId, int chunkSize, KeyValueSource<K,V> keyValueSource, Mapper mapper, CombinerFactory combinerFactory, ReducerFactory reducerFactory, boolean communicateStats, TopologyChangedStrategy topologyChangedStrategy)

Uses of CombinerFactory in com.hazelcast.mapreduce.impl.task

Methods in com.hazelcast.mapreduce.impl.task that return CombinerFactory

Modifier and Type	Method and Description
CombinerFactory	JobTaskConfiguration.getCombinerFactory()

Constructors in com.hazelcast.mapreduce.impl.task with parameters of type CombinerFactory

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)