Uses of Interface
com.hazelcast.mapreduce.ReducerFactory

Packages that use ReducerFactory

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.mapreduce

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

<ValueOut> ReducingSubmittableJob<EntryKey,KeyIn,ValueOut>	ReducingJob.reducer(ReducerFactory<KeyIn,ValueIn,ValueOut> reducerFactory) Defines the ReducerFactory for this task.
<ValueOut> ReducingSubmittableJob<EntryKey,KeyIn,ValueOut>	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

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

ReducerFactory<Key,Long,Long>	LongMinAggregation.getReducerFactory()
ReducerFactory<Key,AvgTuple<Long,BigInteger>,AvgTuple<Long,BigInteger>>	BigIntegerAvgAggregation.getReducerFactory()
ReducerFactory<Key,BigDecimal,BigDecimal>	BigDecimalSumAggregation.getReducerFactory()
ReducerFactory<Key,Long,Long>	LongMaxAggregation.getReducerFactory()
ReducerFactory<Key,BigInteger,BigInteger>	BigIntegerSumAggregation.getReducerFactory()
ReducerFactory<Key,BigDecimal,BigDecimal>	BigDecimalMaxAggregation.getReducerFactory()
ReducerFactory<Key,Comparable,Comparable>	ComparableMinAggregation.getReducerFactory()
ReducerFactory<Key,Integer,Integer>	IntegerMinAggregation.getReducerFactory()
ReducerFactory<Key,Comparable,Comparable>	ComparableMaxAggregation.getReducerFactory()
ReducerFactory<Key,AvgTuple<Integer,Integer>,AvgTuple<Integer,Integer>>	IntegerAvgAggregation.getReducerFactory()
ReducerFactory<Key,Long,Long>	LongSumAggregation.getReducerFactory()
ReducerFactory<Key,AvgTuple<Long,Long>,AvgTuple<Long,Long>>	LongAvgAggregation.getReducerFactory()
ReducerFactory<Key,AvgTuple<Long,Double>,AvgTuple<Long,Double>>	DoubleAvgAggregation.getReducerFactory()
ReducerFactory<Key,Double,Double>	DoubleSumAggregation.getReducerFactory()
ReducerFactory<Key,Integer,Integer>	IntegerSumAggregation.getReducerFactory()
ReducerFactory<Key,Integer,Integer>	IntegerMaxAggregation.getReducerFactory()
ReducerFactory<KeyOut,CombinerValue,ReducerValue>	AggType.getReducerFactory()
ReducerFactory<Key,Double,Double>	DoubleMinAggregation.getReducerFactory()
ReducerFactory<Key,Double,Double>	DoubleMaxAggregation.getReducerFactory()
ReducerFactory<Key,BigInteger,BigInteger>	BigIntegerMinAggregation.getReducerFactory()
ReducerFactory<Integer,Set<DistinctType>,Set<DistinctType>>	DistinctValuesAggregation.getReducerFactory()
ReducerFactory<Key,BigInteger,BigInteger>	BigIntegerMaxAggregation.getReducerFactory()
ReducerFactory<Key,BigDecimal,BigDecimal>	BigDecimalMinAggregation.getReducerFactory()
ReducerFactory<Key,AvgTuple<Long,BigDecimal>,AvgTuple<Long,BigDecimal>>	BigDecimalAvgAggregation.getReducerFactory()
ReducerFactory<Key,Long,Long>	CountAggregation.getReducerFactory()

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

<ValueOut> ReducingSubmittableJob<EntryKey,Key,ValueOut>	AbstractJob.MappingJobImpl.reducer(ReducerFactory<Key,Value,ValueOut> reducerFactory)
<ValueOut> ReducingSubmittableJob<EntryKey,Key,ValueOut>	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)