com.hazelcast.mapreduce.aggregation.impl
Class CountAggregation<Key,Value>
java.lang.Object
com.hazelcast.mapreduce.aggregation.impl.CountAggregation<Key,Value>
- Type Parameters:
Key
- the key input typeValue
- the value input type
- All Implemented Interfaces:
- AggType<Key,Value,Key,Object,Long,Long,Long>
public class CountAggregation<Key,Value>
- extends Object
- implements AggType<Key,Value,Key,Object,Long,Long,Long>
The predefined count aggregation.
Method Summary |
Collator<Map.Entry<Key,Long>,Long> |
getCollator()
|
CombinerFactory<Key,Object,Long> |
getCombinerFactory()
|
Mapper<Key,Value,Key,Object> |
getMapper(Supplier<Key,Value,Object> supplier)
|
ReducerFactory<Key,Long,Long> |
getReducerFactory()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CountAggregation
public CountAggregation()
getCollator
public Collator<Map.Entry<Key,Long>,Long> getCollator()
- Specified by:
getCollator
in interface AggType<Key,Value,Key,Object,Long,Long,Long>
getMapper
public Mapper<Key,Value,Key,Object> getMapper(Supplier<Key,Value,Object> supplier)
- Specified by:
getMapper
in interface AggType<Key,Value,Key,Object,Long,Long,Long>
getCombinerFactory
public CombinerFactory<Key,Object,Long> getCombinerFactory()
- Specified by:
getCombinerFactory
in interface AggType<Key,Value,Key,Object,Long,Long,Long>
getReducerFactory
public ReducerFactory<Key,Long,Long> getReducerFactory()
- Specified by:
getReducerFactory
in interface AggType<Key,Value,Key,Object,Long,Long,Long>
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.