@InterfaceAudience.Public @InterfaceStability.Stable public class UserDefinedValueAggregatorDescriptor extends Object implements ValueAggregatorDescriptor
Modifier and Type | Field and Description |
---|---|
protected ValueAggregatorDescriptor |
theAggregatorDescriptor |
ONE, TYPE_SEPARATOR
Constructor and Description |
---|
UserDefinedValueAggregatorDescriptor(String className,
Configuration conf) |
Modifier and Type | Method and Description |
---|---|
void |
configure(Configuration conf)
Do nothing.
|
static Object |
createInstance(String className)
Create an instance of the given class
|
ArrayList<Map.Entry<Text,Text>> |
generateKeyValPairs(Object key,
Object val)
Generate a list of aggregation-id/value pairs for the given
key/value pairs by delegating the invocation to the real object.
|
String |
toString() |
protected ValueAggregatorDescriptor theAggregatorDescriptor
public UserDefinedValueAggregatorDescriptor(String className, Configuration conf)
className
- the class name of the user defined descriptor classconf
- a configure object used for decriptor configurationpublic static Object createInstance(String className)
className
- the name of the classpublic ArrayList<Map.Entry<Text,Text>> generateKeyValPairs(Object key, Object val)
generateKeyValPairs
in interface ValueAggregatorDescriptor
key
- input keyval
- input valuepublic String toString()
public void configure(Configuration conf)
configure
in interface ValueAggregatorDescriptor
conf
- a Configuration object that may contain the information
that can be used to configure the object.Copyright © 2021 Apache Software Foundation. All rights reserved.