org.apache.hadoop.mapred.lib

クラス MultithreadedMapRunner<K1,V1,K2,V2>

java.lang.Object

org.apache.hadoop.mapred.lib.MultithreadedMapRunner<K1,V1,K2,V2>

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

JobConfigurable, MapRunnable<K1,V1,K2,V2>

@InterfaceAudience.Public
 @InterfaceStability.Stable
public class MultithreadedMapRunner<K1,V1,K2,V2>
extends Object
implements MapRunnable<K1,V1,K2,V2>

Multithreaded implementation for MapRunnable.

It can be used instead of the default implementation, of MapRunner, when the Map operation is not CPU bound in order to improve throughput.

Map implementations using this MapRunnable must be thread-safe.

The Map-Reduce job has to be configured to use this MapRunnable class (using the JobConf.setMapRunnerClass method) and the number of threads the thread-pool can use with the mapred.map.multithreadedrunner.threads property, its default value is 10 threads.

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

コンストラクタ

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

メソッドのサマリー

修飾子とタイプ	メソッドと説明
void	configure(JobConf jobConf) Initializes a new instance from a JobConf.
void	run(RecordReader<K1,V1> input, OutputCollector<K2,V2> output, Reporter reporter) Start mapping input <key, value> pairs.

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

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

コンストラクタの詳細

MultithreadedMapRunner

public MultithreadedMapRunner()

メソッドの詳細

configure

public void configure(JobConf jobConf)

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

Initializes a new instance from a JobConf.

定義:

configure インタフェース内 JobConfigurable

パラメータ:

jobConf - the configuration

run

public void run(RecordReader<K1,V1> input,
                OutputCollector<K2,V2> output,
                Reporter reporter)
         throws IOException

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

Start mapping input <key, value> pairs.

Mapping of input records to output records is complete when this method returns.

定義:

run インタフェース内 MapRunnable<K1,V1,K2,V2>

パラメータ:

input - the RecordReader to read the input records.

output - the OutputCollector to collect the outputrecords.

reporter - Reporter to report progress, status-updates etc.

例外:

IOException