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

java.lang.Object
  extended by 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>>


Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.