org.apache.hadoop.mapred.lib.aggregate

クラス ValueAggregatorJobBase<K1 extends WritableComparable,V1 extends Writable>

java.lang.Object

org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorJobBase<K1,V1>

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

Closeable, AutoCloseable, JobConfigurable, Mapper<K1,V1,Text,Text>, Reducer<Text,Text,Text,Text>

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

ValueAggregatorCombiner, ValueAggregatorMapper, ValueAggregatorReducer

@InterfaceAudience.Public
 @InterfaceStability.Stable
public abstract class ValueAggregatorJobBase<K1 extends WritableComparable,V1 extends Writable>
extends Object
implements Mapper<K1,V1,Text,Text>, Reducer<Text,Text,Text,Text>

This abstract class implements some common functionalities of the the generic mapper, reducer and combiner classes of Aggregate.

フィールドのサマリー

フィールド

修飾子とタイプ	フィールドと説明
protected ArrayList<ValueAggregatorDescriptor>	aggregatorDescriptorList

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

コンストラクタ

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

メソッドのサマリー

修飾子とタイプ	メソッドと説明
void	close()
void	configure(JobConf job) Initializes a new instance from a JobConf.
protected void	logSpec()

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

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

インタフェースから継承されたメソッド org.apache.hadoop.mapred.Mapper

map

インタフェースから継承されたメソッド org.apache.hadoop.mapred.Reducer

reduce

フィールドの詳細

aggregatorDescriptorList

protected ArrayList<ValueAggregatorDescriptor> aggregatorDescriptorList

コンストラクタの詳細

ValueAggregatorJobBase

public ValueAggregatorJobBase()

メソッドの詳細

configure

public void configure(JobConf job)

インタフェースからコピーされた説明: JobConfigurable

Initializes a new instance from a JobConf.

定義:

configure インタフェース内 JobConfigurable

パラメータ:

job - the configuration

logSpec

protected void logSpec()

close

public void close()
           throws IOException

定義:

close インタフェース内 Closeable

定義:

close インタフェース内 AutoCloseable

例外:

IOException