@InterfaceAudience.Public @InterfaceStability.Stable public class ValueAggregatorJobBase<K1 extends WritableComparable<?>,V1 extends Writable> extends Object
Modifier and Type | Field and Description |
---|---|
protected static ArrayList<ValueAggregatorDescriptor> |
aggregatorDescriptorList |
static String |
DESCRIPTOR |
static String |
DESCRIPTOR_NUM |
static String |
USER_JAR |
Constructor and Description |
---|
ValueAggregatorJobBase() |
Modifier and Type | Method and Description |
---|---|
protected static ArrayList<ValueAggregatorDescriptor> |
getAggregatorDescriptors(Configuration conf) |
protected static ValueAggregatorDescriptor |
getValueAggregatorDescriptor(String spec,
Configuration conf) |
protected static void |
logSpec() |
static void |
setup(Configuration job) |
public static final String DESCRIPTOR
public static final String DESCRIPTOR_NUM
public static final String USER_JAR
protected static ArrayList<ValueAggregatorDescriptor> aggregatorDescriptorList
public ValueAggregatorJobBase()
public static void setup(Configuration job)
protected static ValueAggregatorDescriptor getValueAggregatorDescriptor(String spec, Configuration conf)
protected static ArrayList<ValueAggregatorDescriptor> getAggregatorDescriptors(Configuration conf)
protected static void logSpec()
Copyright © 2015 Apache Software Foundation. All rights reserved.