com.hazelcast.mapreduce.aggregation.impl
Interface AggType<KeyIn,ValueIn,KeyOut,SuppliedValue,CombinerValue,ReducerValue,Result>

Type Parameters:
KeyIn - the input key type
ValueIn - the input value type
KeyOut - the mappers output key type
SuppliedValue - the supplied value type
CombinerValue - the pre-reduced (combined) value type
ReducerValue - the reduced value type
Result - the final (mostly collated) value type
All Known Implementing Classes:
BigDecimalAvgAggregation, BigDecimalMaxAggregation, BigDecimalMinAggregation, BigDecimalSumAggregation, BigIntegerAvgAggregation, BigIntegerMaxAggregation, BigIntegerMinAggregation, BigIntegerSumAggregation, ComparableMaxAggregation, ComparableMinAggregation, CountAggregation, DistinctValuesAggregation, DoubleAvgAggregation, DoubleMaxAggregation, DoubleMinAggregation, DoubleSumAggregation, IntegerAvgAggregation, IntegerMaxAggregation, IntegerMinAggregation, IntegerSumAggregation, LongAvgAggregation, LongMaxAggregation, LongMinAggregation, LongSumAggregation

public interface AggType<KeyIn,ValueIn,KeyOut,SuppliedValue,CombinerValue,ReducerValue,Result>

The internal interface for Aggregation definitions to make those implementations more type-safe. Internal AggTypes are adapted to Aggregation using an internal class insideĀ Aggregations which is not part of the public API.


Method Summary
 Collator<Map.Entry<KeyOut,ReducerValue>,Result> getCollator()
           
 CombinerFactory<KeyOut,SuppliedValue,CombinerValue> getCombinerFactory()
           
 Mapper<KeyIn,ValueIn,KeyOut,SuppliedValue> getMapper(Supplier<KeyIn,ValueIn,SuppliedValue> supplier)
           
 ReducerFactory<KeyOut,CombinerValue,ReducerValue> getReducerFactory()
           
 

Method Detail

getCollator

Collator<Map.Entry<KeyOut,ReducerValue>,Result> getCollator()

getMapper

Mapper<KeyIn,ValueIn,KeyOut,SuppliedValue> getMapper(Supplier<KeyIn,ValueIn,SuppliedValue> supplier)

getCombinerFactory

CombinerFactory<KeyOut,SuppliedValue,CombinerValue> getCombinerFactory()

getReducerFactory

ReducerFactory<KeyOut,CombinerValue,ReducerValue> getReducerFactory()


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