Uses of Interface
com.hazelcast.mapreduce.Collator

Packages that use Collator

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

<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 and 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

Collator<Map.Entry,Result>

Aggregation.getCollator() Returns a 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

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

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

protected <T> JobCompletableFuture<T>

KeyValueJob.invoke(Collator collator)

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

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