com.hazelcast.mapreduce.aggregation.impl
Class DistinctValuesAggregation<Key,Value,DistinctType>

java.lang.Object
  com.hazelcast.mapreduce.aggregation.impl.DistinctValuesAggregation<Key,Value,DistinctType>

Type Parameters:

Key - the input key type

Value - the input value type

DistinctType - the common super type for all distinct values

All Implemented Interfaces:

AggType<Key,Value,Integer,DistinctType,Set<DistinctType>,Set<DistinctType>,Set<DistinctType>>

public class DistinctValuesAggregation<Key,Value,DistinctType>
extends Object
implements AggType<Key,Value,Integer,DistinctType,Set<DistinctType>,Set<DistinctType>,Set<DistinctType>>

The predefined distinct value aggregation.

Constructor Summary

DistinctValuesAggregation()

Method Summary

Collator<Map.Entry<Integer,Set<DistinctType>>,Set<DistinctType>>	getCollator()
CombinerFactory<Integer,DistinctType,Set<DistinctType>>	getCombinerFactory()
Mapper<Key,Value,Integer,DistinctType>	getMapper(Supplier<Key,Value,DistinctType> supplier)
ReducerFactory<Integer,Set<DistinctType>,Set<DistinctType>>	getReducerFactory()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DistinctValuesAggregation

public DistinctValuesAggregation()

Method Detail

getCollator

public Collator<Map.Entry<Integer,Set<DistinctType>>,Set<DistinctType>> getCollator()

Specified by:

getCollator in interface AggType<Key,Value,Integer,DistinctType,Set<DistinctType>,Set<DistinctType>,Set<DistinctType>>

getMapper

public Mapper<Key,Value,Integer,DistinctType> getMapper(Supplier<Key,Value,DistinctType> supplier)

Specified by:

getMapper in interface AggType<Key,Value,Integer,DistinctType,Set<DistinctType>,Set<DistinctType>,Set<DistinctType>>

getCombinerFactory

public CombinerFactory<Integer,DistinctType,Set<DistinctType>> getCombinerFactory()

Specified by:

getCombinerFactory in interface AggType<Key,Value,Integer,DistinctType,Set<DistinctType>,Set<DistinctType>,Set<DistinctType>>

getReducerFactory

public ReducerFactory<Integer,Set<DistinctType>,Set<DistinctType>> getReducerFactory()

Specified by:

getReducerFactory in interface AggType<Key,Value,Integer,DistinctType,Set<DistinctType>,Set<DistinctType>,Set<DistinctType>>