Class ValueAggregatorJobBase<K1 extends WritableComparable<?>,V1 extends Writable>
java.lang.Object
org.apache.hadoop.mapreduce.lib.aggregate.ValueAggregatorJobBase<K1,V1>
@Public
@Stable
public class ValueAggregatorJobBase<K1 extends WritableComparable<?>,V1 extends Writable>
extends Object
This abstract class implements some common functionalities of the
the generic mapper, reducer and combiner classes of Aggregate.
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected static ArrayList<ValueAggregatorDescriptor>static final Stringstatic final Stringstatic final String -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected static ArrayList<ValueAggregatorDescriptor>protected static ValueAggregatorDescriptorgetValueAggregatorDescriptor(String spec, Configuration conf) protected static voidlogSpec()static voidsetup(Configuration job)
-
Field Details
-
DESCRIPTOR
- See Also:
-
DESCRIPTOR_NUM
- See Also:
-
USER_JAR
- See Also:
-
aggregatorDescriptorList
-
-
Constructor Details
-
ValueAggregatorJobBase
public ValueAggregatorJobBase()
-
-
Method Details
-
setup
-
getValueAggregatorDescriptor
protected static ValueAggregatorDescriptor getValueAggregatorDescriptor(String spec, Configuration conf) -
getAggregatorDescriptors
-
logSpec
protected static void logSpec()
-