Uses of Interface
com.hazelcast.mapreduce.Mapper

Packages that use Mapper

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.

Uses of Mapper in com.hazelcast.client.impl.protocol.task.mapreduce

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

Modifier and Type	Method and Description
protected Mapper	MapReduceForMapMessageTask.getMapper()
protected Mapper	MapReduceForSetMessageTask.getMapper()
protected abstract Mapper	AbstractMapReduceTask.getMapper()
protected Mapper	MapReduceForCustomMessageTask.getMapper()
protected Mapper	MapReduceForListMessageTask.getMapper()
protected Mapper	MapReduceForMultiMapMessageTask.getMapper()

Uses of Mapper in com.hazelcast.mapreduce

Subinterfaces of Mapper in com.hazelcast.mapreduce

Modifier and Type	Interface and Description
interface	LifecycleMapper<KeyIn,ValueIn,KeyOut,ValueOut> The LifecycleMapper interface is a more sophisticated version of Mapper normally used for more complex algorithms with a need for initialization and finalization.

Classes in com.hazelcast.mapreduce that implement Mapper

Modifier and Type	Class and Description
class	LifecycleMapperAdapter<KeyIn,ValueIn,KeyOut,ValueOut> The abstract LifecycleMapperAdapter superclass is used to ease building mappers for the Job.

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

Modifier and Type	Method and Description
<KeyOut,ValueOut> MappingJob<KeyIn,KeyOut,ValueOut>	Job.mapper(Mapper<KeyIn,ValueIn,KeyOut,ValueOut> mapper) Defines the mapper for this task.

Uses of Mapper in com.hazelcast.mapreduce.aggregation

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

Modifier and Type	Method and Description
Mapper	Aggregation.getMapper(Supplier<Key,?,Supplied> supplier) Returns the Mapper for this aggregation.

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

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

Modifier and Type	Method and Description
Mapper<KeyIn,ValueIn,KeyOut,SuppliedValue>	AggType.getMapper(Supplier<KeyIn,ValueIn,SuppliedValue> supplier)
Mapper<Key,Value,Key,BigDecimal>	BigDecimalSumAggregation.getMapper(Supplier<Key,Value,BigDecimal> supplier)
Mapper<Key,Value,Key,BigDecimal>	BigDecimalMaxAggregation.getMapper(Supplier<Key,Value,BigDecimal> supplier)
Mapper<Key,Value,Key,BigDecimal>	BigDecimalMinAggregation.getMapper(Supplier<Key,Value,BigDecimal> supplier)
Mapper<Key,Value,Key,BigDecimal>	BigDecimalAvgAggregation.getMapper(Supplier<Key,Value,BigDecimal> supplier)
Mapper<Key,Value,Key,BigInteger>	BigIntegerAvgAggregation.getMapper(Supplier<Key,Value,BigInteger> supplier)
Mapper<Key,Value,Key,BigInteger>	BigIntegerSumAggregation.getMapper(Supplier<Key,Value,BigInteger> supplier)
Mapper<Key,Value,Key,BigInteger>	BigIntegerMinAggregation.getMapper(Supplier<Key,Value,BigInteger> supplier)
Mapper<Key,Value,Key,BigInteger>	BigIntegerMaxAggregation.getMapper(Supplier<Key,Value,BigInteger> supplier)
Mapper<Key,Value,Key,Comparable>	ComparableMinAggregation.getMapper(Supplier<Key,Value,Comparable> supplier)
Mapper<Key,Value,Key,Comparable>	ComparableMaxAggregation.getMapper(Supplier<Key,Value,Comparable> supplier)
Mapper<Key,Value,Integer,DistinctType>	DistinctValuesAggregation.getMapper(Supplier<Key,Value,DistinctType> supplier)
Mapper<Key,Value,Key,Double>	DoubleAvgAggregation.getMapper(Supplier<Key,Value,Double> supplier)
Mapper<Key,Value,Key,Double>	DoubleSumAggregation.getMapper(Supplier<Key,Value,Double> supplier)
Mapper<Key,Value,Key,Double>	DoubleMinAggregation.getMapper(Supplier<Key,Value,Double> supplier)
Mapper<Key,Value,Key,Double>	DoubleMaxAggregation.getMapper(Supplier<Key,Value,Double> supplier)
Mapper<Key,Value,Key,Integer>	IntegerMinAggregation.getMapper(Supplier<Key,Value,Integer> supplier)
Mapper<Key,Value,Key,Integer>	IntegerAvgAggregation.getMapper(Supplier<Key,Value,Integer> supplier)
Mapper<Key,Value,Key,Integer>	IntegerSumAggregation.getMapper(Supplier<Key,Value,Integer> supplier)
Mapper<Key,Value,Key,Integer>	IntegerMaxAggregation.getMapper(Supplier<Key,Value,Integer> supplier)
Mapper<Key,Value,Key,Long>	LongMinAggregation.getMapper(Supplier<Key,Value,Long> supplier)
Mapper<Key,Value,Key,Long>	LongMaxAggregation.getMapper(Supplier<Key,Value,Long> supplier)
Mapper<Key,Value,Key,Long>	LongSumAggregation.getMapper(Supplier<Key,Value,Long> supplier)
Mapper<Key,Value,Key,Long>	LongAvgAggregation.getMapper(Supplier<Key,Value,Long> supplier)
Mapper<Key,Value,Key,Object>	CountAggregation.getMapper(Supplier<Key,Value,Object> supplier)

Uses of Mapper in com.hazelcast.mapreduce.impl

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

Modifier and Type	Field and Description
protected Mapper<KeyIn,ValueIn,?,?>	AbstractJob.mapper

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

Modifier and Type	Method and Description
<KeyOut,ValueOut> MappingJob<KeyIn,KeyOut,ValueOut>	AbstractJob.mapper(Mapper<KeyIn,ValueIn,KeyOut,ValueOut> mapper)

Uses of Mapper in com.hazelcast.mapreduce.impl.client

Fields in com.hazelcast.mapreduce.impl.client declared as Mapper

Modifier and Type	Field and Description
protected Mapper	ClientMapReduceRequest.mapper

Constructors in com.hazelcast.mapreduce.impl.client with parameters of type Mapper

Constructor and Description
ClientMapReduceRequest(String name, String jobId, Collection keys, KeyPredicate predicate, Mapper mapper, CombinerFactory combinerFactory, ReducerFactory reducerFactory, KeyValueSource keyValueSource, int chunkSize, TopologyChangedStrategy topologyChangedStrategy)

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

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

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 Mapper in com.hazelcast.mapreduce.impl.task

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

Modifier and Type	Method and Description
Mapper	JobTaskConfiguration.getMapper()

Methods in com.hazelcast.mapreduce.impl.task with parameters of type Mapper

Modifier and Type	Method and Description
void	KeyValueSourceMappingPhase.executeMappingPhase(KeyValueSource<KeyIn,ValueIn> keyValueSource, Mapper<KeyIn,ValueIn,KeyOut,ValueOut> mapper, Context<KeyOut,ValueOut> context)
protected abstract void	MappingPhase.executeMappingPhase(KeyValueSource<KeyIn,ValueIn> keyValueSource, Mapper<KeyIn,ValueIn,KeyOut,ValueOut> mapper, Context<KeyOut,ValueOut> context)

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

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)