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()