big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

MAPREDUCE-2815. JavaDoc does not generate correctly for MultithreadedMapRunner. Contributed by Chris Palmer.

Browse Source
This commit is contained in:
Akira Ajisaka 2015-02-24 12:10:17 -08:00
parent 0d7d508c82
commit 9a37247a67
2 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-mapreduce-project/CHANGES.txt
View File

@ -387,6 +387,9 @@ Release 2.7.0 - UNRELEASED
MAPREDUCE-6261. NullPointerException if MapOutputBuffer.flush invoked MAPREDUCE-6261. NullPointerException if MapOutputBuffer.flush invoked
twice (Tsuyoshi OZAWA via jlowe) twice (Tsuyoshi OZAWA via jlowe)
MAPREDUCE-2815. JavaDoc does not generate correctly for
MultithreadedMapRunner. (Chris Palmer via aajisaka)
Release 2.6.1 - UNRELEASED Release 2.6.1 - UNRELEASED
INCOMPATIBLE CHANGES INCOMPATIBLE CHANGES

8
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/lib/MultithreadedMapRunner.java
View File

@ -36,17 +36,17 @@
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 * of {@link org.apache.hadoop.mapred.MapRunner}, when the Map
* bound in order to improve throughput. * 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>