Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

MAPREDUCE-6865. Fix typo in javadoc for DistributedCache. Contributed by Attila Sasvari.

This commit is contained in:
Naganarasimha 2017-03-20 00:04:23 +05:30
parent ffa160ddb8
commit 34a931c0fa
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/filecache/DistributedCache.java
View File

@ -83,11 +83,11 @@ import org.apache.hadoop.mapreduce.MRJobConfig;
* JobConf job = new JobConf(); * JobConf job = new JobConf();
* DistributedCache.addCacheFile(new URI("/myapp/lookup.dat#lookup.dat"), * DistributedCache.addCacheFile(new URI("/myapp/lookup.dat#lookup.dat"),
* job); * job);
* DistributedCache.addCacheArchive(new URI("/myapp/map.zip", job); * DistributedCache.addCacheArchive(new URI("/myapp/map.zip"), job);
* DistributedCache.addFileToClassPath(new Path("/myapp/mylib.jar"), job); * DistributedCache.addFileToClassPath(new Path("/myapp/mylib.jar"), job);
* DistributedCache.addCacheArchive(new URI("/myapp/mytar.tar", job); * DistributedCache.addCacheArchive(new URI("/myapp/mytar.tar"), job);
* DistributedCache.addCacheArchive(new URI("/myapp/mytgz.tgz", job); * DistributedCache.addCacheArchive(new URI("/myapp/mytgz.tgz"), job);
* DistributedCache.addCacheArchive(new URI("/myapp/mytargz.tar.gz", job); * DistributedCache.addCacheArchive(new URI("/myapp/mytargz.tar.gz"), job);
* *
* 3. Use the cached files in the {@link org.apache.hadoop.mapred.Mapper} * 3. Use the cached files in the {@link org.apache.hadoop.mapred.Mapper}
* or {@link org.apache.hadoop.mapred.Reducer}: * or {@link org.apache.hadoop.mapred.Reducer}:

8
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/filecache/DistributedCache.java
View File

@ -85,11 +85,11 @@ import java.net.URI;
* JobConf job = new JobConf(); * JobConf job = new JobConf();
* DistributedCache.addCacheFile(new URI("/myapp/lookup.dat#lookup.dat"), * DistributedCache.addCacheFile(new URI("/myapp/lookup.dat#lookup.dat"),
* job); * job);
* DistributedCache.addCacheArchive(new URI("/myapp/map.zip", job); * DistributedCache.addCacheArchive(new URI("/myapp/map.zip"), job);
* DistributedCache.addFileToClassPath(new Path("/myapp/mylib.jar"), job); * DistributedCache.addFileToClassPath(new Path("/myapp/mylib.jar"), job);
* DistributedCache.addCacheArchive(new URI("/myapp/mytar.tar", job); * DistributedCache.addCacheArchive(new URI("/myapp/mytar.tar"), job);
* DistributedCache.addCacheArchive(new URI("/myapp/mytgz.tgz", job); * DistributedCache.addCacheArchive(new URI("/myapp/mytgz.tgz"), job);
* DistributedCache.addCacheArchive(new URI("/myapp/mytargz.tar.gz", job); * DistributedCache.addCacheArchive(new URI("/myapp/mytargz.tar.gz"), job);
* *
* 3. Use the cached files in the {@link org.apache.hadoop.mapred.Mapper} * 3. Use the cached files in the {@link org.apache.hadoop.mapred.Mapper}
* or {@link org.apache.hadoop.mapred.Reducer}: * or {@link org.apache.hadoop.mapred.Reducer}: