|
Class Summary |
| DoubleValueSum |
This class implements a value aggregator that sums up a sequence of double
values. |
| LongValueMax |
This class implements a value aggregator that maintain the maximum of
a sequence of long values. |
| LongValueMin |
This class implements a value aggregator that maintain the minimum of
a sequence of long values. |
| LongValueSum |
This class implements a value aggregator that sums up
a sequence of long values. |
| StringValueMax |
This class implements a value aggregator that maintain the biggest of
a sequence of strings. |
| StringValueMin |
This class implements a value aggregator that maintain the smallest of
a sequence of strings. |
| UniqValueCount |
This class implements a value aggregator that dedupes a sequence of objects. |
| UserDefinedValueAggregatorDescriptor |
This class implements a wrapper for a user defined value aggregator
descriptor. |
| ValueAggregatorBaseDescriptor |
This class implements the common functionalities of
the subclasses of ValueAggregatorDescriptor class. |
| ValueAggregatorCombiner<K1 extends WritableComparable,V1 extends Writable> |
This class implements the generic combiner of Aggregate. |
| ValueAggregatorJob |
This is the main class for creating a map/reduce job using Aggregate
framework. |
| ValueAggregatorJobBase<K1 extends WritableComparable,V1 extends Writable> |
This abstract class implements some common functionalities of the
the generic mapper, reducer and combiner classes of Aggregate. |
| ValueAggregatorMapper<K1 extends WritableComparable,V1 extends Writable> |
This class implements the generic mapper of Aggregate. |
| ValueAggregatorReducer<K1 extends WritableComparable,V1 extends Writable> |
This class implements the generic reducer of Aggregate. |
| ValueHistogram |
This class implements a value aggregator that computes the
histogram of a sequence of strings. |