Uses of Interface
com.hazelcast.mapreduce.Collator

Packages that use Collator

Package	Description
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.task	This package contains the base implementation for a standard map reduce job.

Uses of Collator in com.hazelcast.mapreduce

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

Modifier and Type	Method and Description
<ValueOut> JobCompletableFuture<ValueOut>	ReducingJob.submit(Collator<Map.Entry<KeyIn,List<ValueIn>>,ValueOut> collator) Submits the task to Hazelcast and executes the defined mapper and reducer on all cluster nodes and executes the collator before returning the final result.
<ValueOut> JobCompletableFuture<ValueOut>	MappingJob.submit(Collator<Map.Entry<KeyIn,List<ValueIn>>,ValueOut> collator) Submits the task to Hazelcast, executes the defined mapper and reducer on all cluster nodes, and executes the collator before returning the final result.
<ValueOut> JobCompletableFuture<ValueOut>	ReducingSubmittableJob.submit(Collator<Map.Entry<KeyIn,ValueIn>,ValueOut> collator) Submits the task to Hazelcast and executes the defined mapper and reducer on all cluster nodes and executes the collator before returning the final result.

Uses of Collator in com.hazelcast.mapreduce.aggregation

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

Modifier and Type	Method and Description
Collator<Map.Entry,Result>	Aggregation.getCollator() Returns the Collator implementation used in this aggregation.

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

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

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

Uses of Collator in com.hazelcast.mapreduce.impl

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

Modifier and Type	Method and Description
protected abstract <T> JobCompletableFuture<T>	AbstractJob.invoke(Collator collator)
protected <T> JobCompletableFuture<T>	AbstractJob.submit(Collator collator)
<ValueOut> JobCompletableFuture<ValueOut>	AbstractJob.MappingJobImpl.submit(Collator<Map.Entry<Key,List<Value>>,ValueOut> collator)
<ValueOut> JobCompletableFuture<ValueOut>	AbstractJob.ReducingJobImpl.submit(Collator<Map.Entry<Key,List<Value>>,ValueOut> collator)
<ValueOut> JobCompletableFuture<ValueOut>	AbstractJob.ReducingSubmittableJobImpl.submit(Collator<Map.Entry<Key,Value>,ValueOut> collator)

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

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

Modifier and Type	Method and Description
protected <T> JobCompletableFuture<T>	KeyValueJob.invoke(Collator collator)

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

Constructor and Description
TrackableJobFuture(String name, String jobId, JobTracker jobTracker, NodeEngine nodeEngine, Collator collator)