org.apache.hadoop.mapred.lib.aggregate
Class ValueAggregatorBaseDescriptor
java.lang.Object
org.apache.hadoop.mapreduce.lib.aggregate.ValueAggregatorBaseDescriptor
org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorBaseDescriptor
- All Implemented Interfaces:
- ValueAggregatorDescriptor
@InterfaceAudience.Public
@InterfaceStability.Stable
public class ValueAggregatorBaseDescriptor
- extends ValueAggregatorBaseDescriptor
- implements ValueAggregatorDescriptor
This class implements the common functionalities of
the subclasses of ValueAggregatorDescriptor class.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
UNIQ_VALUE_COUNT
public static final String UNIQ_VALUE_COUNT
- See Also:
- Constant Field Values
LONG_VALUE_SUM
public static final String LONG_VALUE_SUM
- See Also:
- Constant Field Values
DOUBLE_VALUE_SUM
public static final String DOUBLE_VALUE_SUM
- See Also:
- Constant Field Values
VALUE_HISTOGRAM
public static final String VALUE_HISTOGRAM
- See Also:
- Constant Field Values
LONG_VALUE_MAX
public static final String LONG_VALUE_MAX
- See Also:
- Constant Field Values
LONG_VALUE_MIN
public static final String LONG_VALUE_MIN
- See Also:
- Constant Field Values
STRING_VALUE_MAX
public static final String STRING_VALUE_MAX
- See Also:
- Constant Field Values
STRING_VALUE_MIN
public static final String STRING_VALUE_MIN
- See Also:
- Constant Field Values
ValueAggregatorBaseDescriptor
public ValueAggregatorBaseDescriptor()
generateEntry
public static Map.Entry<Text,Text> generateEntry(String type,
String id,
Text val)
- Parameters:
type
- the aggregation typeid
- the aggregation idval
- the val associated with the id to be aggregated
- Returns:
- an Entry whose key is the aggregation id prefixed with
the aggregation type.
generateValueAggregator
public static ValueAggregator generateValueAggregator(String type)
- Parameters:
type
- the aggregation type
- Returns:
- a value aggregator of the given type.
configure
public void configure(JobConf job)
- get the input file name.
- Parameters:
job
- a job configuration object
Copyright © 2014 Apache Software Foundation. All Rights Reserved.