org.apache.hadoop.mapred.lib.aggregate

クラス ValueAggregatorBaseDescriptor

java.lang.Object

org.apache.hadoop.mapreduce.lib.aggregate.ValueAggregatorBaseDescriptor

org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorBaseDescriptor

すべての実装されたインタフェース:

ValueAggregatorDescriptor

@InterfaceAudience.Public
 @InterfaceStability.Stable
public class ValueAggregatorBaseDescriptor
extends ValueAggregatorBaseDescriptor
implements ValueAggregatorDescriptor

This class implements the common functionalities of the subclasses of ValueAggregatorDescriptor class.

フィールドのサマリー

フィールド

修飾子とタイプ	フィールドと説明
static String	DOUBLE_VALUE_SUM
static String	LONG_VALUE_MAX
static String	LONG_VALUE_MIN
static String	LONG_VALUE_SUM
static String	STRING_VALUE_MAX
static String	STRING_VALUE_MIN
static String	UNIQ_VALUE_COUNT
static String	VALUE_HISTOGRAM

クラスから継承されたフィールド org.apache.hadoop.mapreduce.lib.aggregate.ValueAggregatorBaseDescriptor

inputFile

インタフェースから継承されたフィールド org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorDescriptor

ONE, TYPE_SEPARATOR

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
ValueAggregatorBaseDescriptor()

メソッドのサマリー

修飾子とタイプ	メソッドと説明
void	configure(JobConf job) get the input file name.
static Map.Entry<Text,Text>	generateEntry(String type, String id, Text val)
static ValueAggregator	generateValueAggregator(String type)

クラスから継承されたメソッド org.apache.hadoop.mapreduce.lib.aggregate.ValueAggregatorBaseDescriptor

configure, generateKeyValPairs, generateValueAggregator

クラスから継承されたメソッド java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

インタフェースから継承されたメソッド org.apache.hadoop.mapreduce.lib.aggregate.ValueAggregatorDescriptor

configure, generateKeyValPairs

フィールドの詳細

UNIQ_VALUE_COUNT

public static final String UNIQ_VALUE_COUNT

関連項目:

定数フィールド値

LONG_VALUE_SUM

public static final String LONG_VALUE_SUM

関連項目:

定数フィールド値

DOUBLE_VALUE_SUM

public static final String DOUBLE_VALUE_SUM

関連項目:

定数フィールド値

VALUE_HISTOGRAM

public static final String VALUE_HISTOGRAM

関連項目:

定数フィールド値

LONG_VALUE_MAX

public static final String LONG_VALUE_MAX

関連項目:

定数フィールド値

LONG_VALUE_MIN

public static final String LONG_VALUE_MIN

関連項目:

定数フィールド値

STRING_VALUE_MAX

public static final String STRING_VALUE_MAX

関連項目:

定数フィールド値

STRING_VALUE_MIN

public static final String STRING_VALUE_MIN

関連項目:

定数フィールド値

コンストラクタの詳細

ValueAggregatorBaseDescriptor

public ValueAggregatorBaseDescriptor()

メソッドの詳細

generateEntry

public static Map.Entry<Text,Text> generateEntry(String type,
                                                 String id,
                                                 Text val)

パラメータ:

type - the aggregation type

id - the aggregation id

val - the val associated with the id to be aggregated

戻り値:

an Entry whose key is the aggregation id prefixed with the aggregation type.

generateValueAggregator

public static ValueAggregator generateValueAggregator(String type)

パラメータ:

type - the aggregation type

戻り値:

a value aggregator of the given type.

configure

public void configure(JobConf job)

get the input file name.

パラメータ:

job - a job configuration object