org.apache.hadoop.mapreduce.lib.aggregate

クラス UniqValueCount

java.lang.Object

org.apache.hadoop.mapreduce.lib.aggregate.UniqValueCount

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

ValueAggregator<Object>

直系の既知のサブクラス:

UniqValueCount

@InterfaceAudience.Public
 @InterfaceStability.Stable
public class UniqValueCount
extends Object
implements ValueAggregator<Object>

This class implements a value aggregator that dedupes a sequence of objects.

フィールドのサマリー

フィールド

修飾子とタイプ	フィールドと説明
static String	MAX_NUM_UNIQUE_VALUES

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

コンストラクタ

コンストラクタと説明
UniqValueCount() the default constructor
UniqValueCount(long maxNum) constructor

メソッドのサマリー

修飾子とタイプ	メソッドと説明
void	addNextValue(Object val) add a value to the aggregator
ArrayList<Object>	getCombinerOutput()
String	getReport()
Set<Object>	getUniqueItems()
void	reset() reset the aggregator
long	setMaxItems(long n) Set the limit on the number of unique values

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

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

フィールドの詳細

MAX_NUM_UNIQUE_VALUES

public static final String MAX_NUM_UNIQUE_VALUES

関連項目:

定数フィールド値

コンストラクタの詳細

UniqValueCount

public UniqValueCount()

the default constructor

UniqValueCount

public UniqValueCount(long maxNum)

constructor

パラメータ:

maxNum - the limit in the number of unique values to keep.

メソッドの詳細

setMaxItems

public long setMaxItems(long n)

Set the limit on the number of unique values

パラメータ:

n - the desired limit on the number of unique values

戻り値:

the new limit on the number of unique values

addNextValue

public void addNextValue(Object val)

add a value to the aggregator

定義:

addNextValue インタフェース内 ValueAggregator<Object>

パラメータ:

val - an object.

getReport

public String getReport()

定義:

getReport インタフェース内 ValueAggregator<Object>

戻り値:

return the number of unique objects aggregated

getUniqueItems

public Set<Object> getUniqueItems()

戻り値:

the set of the unique objects

reset

public void reset()

reset the aggregator

定義:

reset インタフェース内 ValueAggregator<Object>

getCombinerOutput

public ArrayList<Object> getCombinerOutput()

定義:

getCombinerOutput インタフェース内 ValueAggregator<Object>

戻り値:

return an array of the unique objects. The return value is expected to be used by the a combiner.