|
@@ -36,17 +36,17 @@ import java.io.IOException;
|
|
import java.util.concurrent.*;
|
|
import java.util.concurrent.*;
|
|
|
|
|
|
/**
|
|
/**
|
|
- * Multithreaded implementation for @link org.apache.hadoop.mapred.MapRunnable.
|
|
|
|
|
|
+ * Multithreaded implementation for {@link MapRunnable}.
|
|
* <p>
|
|
* <p>
|
|
* It can be used instead of the default implementation,
|
|
* It can be used instead of the default implementation,
|
|
- * @link org.apache.hadoop.mapred.MapRunner, when the Map operation is not CPU
|
|
|
|
- * bound in order to improve throughput.
|
|
|
|
|
|
+ * of {@link org.apache.hadoop.mapred.MapRunner}, when the Map
|
|
|
|
+ * operation is not CPU bound in order to improve throughput.
|
|
* <p>
|
|
* <p>
|
|
* Map implementations using this MapRunnable must be thread-safe.
|
|
* Map implementations using this MapRunnable must be thread-safe.
|
|
* <p>
|
|
* <p>
|
|
* The Map-Reduce job has to be configured to use this MapRunnable class (using
|
|
* The Map-Reduce job has to be configured to use this MapRunnable class (using
|
|
* the JobConf.setMapRunnerClass method) and
|
|
* the JobConf.setMapRunnerClass method) and
|
|
- * the number of thread the thread-pool can use with the
|
|
|
|
|
|
+ * the number of threads the thread-pool can use with the
|
|
* <code>mapred.map.multithreadedrunner.threads</code> property, its default
|
|
* <code>mapred.map.multithreadedrunner.threads</code> property, its default
|
|
* value is 10 threads.
|
|
* value is 10 threads.
|
|
* <p>
|
|
* <p>
|