org.apache.hadoop.mapred.lib.aggregate

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

java.lang.Object

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

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

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

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

@InterfaceAudience.Public
 @InterfaceStability.Stable
public class ValueAggregatorCombiner<K1 extends WritableComparable,V1 extends Writable>
extends ValueAggregatorJobBase<K1,V1>

This class implements the generic combiner of Aggregate.

フィールドのサマリー

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

aggregatorDescriptorList

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

コンストラクタ

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

メソッドのサマリー

修飾子とタイプ	メソッドと説明
void	close() Do nothing.
void	configure(JobConf job) Combiner does not need to configure.
void	map(K1 arg0, V1 arg1, OutputCollector<Text,Text> arg2, Reporter arg3) Do nothing.
void	reduce(Text key, Iterator<Text> values, OutputCollector<Text,Text> output, Reporter reporter) Combines values for a given key.

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

logSpec

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

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

コンストラクタの詳細

ValueAggregatorCombiner

public ValueAggregatorCombiner()

メソッドの詳細

configure

public void configure(JobConf job)

Combiner does not need to configure.

定義:

configure インタフェース内 JobConfigurable

オーバーライド:

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

パラメータ:

job - the configuration

reduce

public void reduce(Text key,
                   Iterator<Text> values,
                   OutputCollector<Text,Text> output,
                   Reporter reporter)
            throws IOException

Combines values for a given key.

パラメータ:

key - the key is expected to be a Text object, whose prefix indicates the type of aggregation to aggregate the values.

values - the values to combine

output - to collect combined values

reporter - facility to report progress.

例外:

IOException

close

public void close()
           throws IOException

Do nothing.

定義:

close インタフェース内 Closeable

定義:

close インタフェース内 AutoCloseable

オーバーライド:

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

例外:

IOException

map

public void map(K1 arg0,
                V1 arg1,
                OutputCollector<Text,Text> arg2,
                Reporter arg3)
         throws IOException

Do nothing. Should not be called.

パラメータ:

arg0 - the input key.

arg1 - the input value.

arg2 - collects mapped keys and values.

arg3 - facility to report progress.

例外:

IOException