public static class AggregateWordHistogram.AggregateWordHistogramPlugin extends ValueAggregatorBaseDescriptor
DOUBLE_VALUE_SUM, inputFile, LONG_VALUE_MAX, LONG_VALUE_MIN, LONG_VALUE_SUM, STRING_VALUE_MAX, STRING_VALUE_MIN, UNIQ_VALUE_COUNT, VALUE_HISTOGRAM
ONE, TYPE_SEPARATOR
Constructor and Description |
---|
AggregateWordHistogram.AggregateWordHistogramPlugin() |
Modifier and Type | Method and Description |
---|---|
java.util.ArrayList<java.util.Map.Entry<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> |
generateKeyValPairs(java.lang.Object key,
java.lang.Object val)
Parse the given value, generate an aggregation-id/value pair per word.
|
configure, generateEntry, generateValueAggregator
public AggregateWordHistogram.AggregateWordHistogramPlugin()
public java.util.ArrayList<java.util.Map.Entry<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> generateKeyValPairs(java.lang.Object key, java.lang.Object val)
generateKeyValPairs
in interface ValueAggregatorDescriptor
generateKeyValPairs
in class ValueAggregatorBaseDescriptor
key
- input keyval
- input valueCopyright © 2009 The Apache Software Foundation