Package com.hazelcast.mapreduce.aggregation.impl

This package contains a set of predefined aggregation implementations

See:
Description

Interface Summary

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

The internal interface for Aggregation definitions to make those implementations more type-safe.

Class Summary

AcceptAllSupplier<KeyIn,ValueIn,ValueOut>	A standard implementation of the Supplier interface which accepts all input values and may apply a given PropertyExtractor on those.
AggregationsDataSerializerHook	This class contains all the ID hooks for IdentifiedDataSerializable classes used for aggregations.
AvgTuple<F,S>	Internal tuple type for average calculations, used to transmit data between Combiner and Reducer implementations.
BigDecimalAvgAggregation<Key,Value>	The predefined average aggregation for values of type BigDecimal.
BigDecimalMaxAggregation<Key,Value>	The predefined maximum aggregation for values of type BigDecimal.
BigDecimalMinAggregation<Key,Value>	The predefined minimum aggregation for values of type BigDecimal.
BigDecimalSumAggregation<Key,Value>	The predefined sum aggregation for values of type BigDecimal.
BigIntegerAvgAggregation<Key,Value>	The predefined average aggregation for values of type BigInteger.
BigIntegerMaxAggregation<Key,Value>	The predefined maximum aggregation for values of type BigInteger.
BigIntegerMinAggregation<Key,Value>	The predefined minimum aggregation for values of type BigInteger.
BigIntegerSumAggregation<Key,Value>	The predefined sum aggregation for values of type BigInteger.
ComparableMaxAggregation<Key,Value>	The predefined maximum aggregation for values of type Comparable.
ComparableMinAggregation<Key,Value>	The predefined minimum aggregation for values of type Comparable.
CountAggregation<Key,Value>	The predefined count aggregation.
DistinctValuesAggregation<Key,Value,DistinctType>	The predefined distinct value aggregation.
DoubleAvgAggregation<Key,Value>	The predefined average aggregation for values of type double.
DoubleMaxAggregation<Key,Value>	The predefined maximum aggregation for values of type double.
DoubleMinAggregation<Key,Value>	The predefined minimum aggregation for values of type double.
DoubleSumAggregation<Key,Value>	The predefined sum aggregation for values of type double.
IntegerAvgAggregation<Key,Value>	The predefined average aggregation for values of type integer.
IntegerMaxAggregation<Key,Value>	The predefined maximum aggregation for values of type integer.
IntegerMinAggregation<Key,Value>	The predefined minimum aggregation for values of type integer.
IntegerSumAggregation<Key,Value>	The predefined sum aggregation for values of type integer.
KeyPredicateSupplier<KeyIn,ValueIn,ValueOut>	The default supplier for KeyPredicates, used to filter and optionally transform data (using the given Supplier).
LongAvgAggregation<Key,Value>	The predefined average aggregation for values of type long.
LongMaxAggregation<Key,Value>	The predefined maximum aggregation for values of type long.
LongMinAggregation<Key,Value>	The predefined minimum aggregation for values of type long.
LongSumAggregation<Key,Value>	The predefined sum aggregation for values of type long.
PredicateSupplier<KeyIn,ValueIn,ValueOut>	The default supplier for Predicates, used to filter and optionally transform data (using the given Supplier).
SetAdapter<E>	A simple adapter class to serialize values of a Set using Hazelcast serialization support.

Package com.hazelcast.mapreduce.aggregation.impl Description

This package contains a set of predefined aggregation implementations