Author: omalley
Date: Thu Aug 28 23:16:07 2008
New Revision: 690117
URL: http://svn.apache.org/viewvc?rev=690117&view=rev
Log:
HADOOP-3769. Make the SampleMapper and SampleReducer from
GenericMRLoadGenerator public, so they can be used in other contexts.
(Lingyun Yang via omalley)
Modified:
hadoop/core/trunk/CHANGES.txt
hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/jobcontrol/Job.java
hadoop/core/trunk/src/test/org/apache/hadoop/mapred/GenericMRLoadGenerator.java
Modified: hadoop/core/trunk/CHANGES.txt
URL:
http://svn.apache.org/viewvc/hadoop/core/trunk/CHANGES.txt?rev=690117&r1=690116&r2=690117&view=diff
==============================================================================
--- hadoop/core/trunk/CHANGES.txt (original)
+++ hadoop/core/trunk/CHANGES.txt Thu Aug 28 23:16:07 2008
@@ -267,6 +267,10 @@
HADOOP-2130. Pipes submit job should have both blocking and non-blocking
versions. (acmurthy via omalley)
+ HADOOP-3769. Make the SampleMapper and SampleReducer from
+ GenericMRLoadGenerator public, so they can be used in other contexts.
+ (Lingyun Yang via omalley)
+
BUG FIXES
HADOOP-3563. Refactor the distributed upgrade code so that it is
Modified:
hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/jobcontrol/Job.java
URL:
http://svn.apache.org/viewvc/hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/jobcontrol/Job.java?rev=690117&r1=690116&r2=690117&view=diff
==============================================================================
--- hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/jobcontrol/Job.java
(original)
+++ hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/jobcontrol/Job.java
Thu Aug 28 23:16:07 2008
@@ -224,6 +224,14 @@
this.message = message;
}
+
+ /**
+ * @return the job client of this job
+ */
+ public JobClient getJobClient(){
+ return this.jc;
+ }
+
/**
* @return the depending jobs of this job
*/
Modified:
hadoop/core/trunk/src/test/org/apache/hadoop/mapred/GenericMRLoadGenerator.java
URL:
http://svn.apache.org/viewvc/hadoop/core/trunk/src/test/org/apache/hadoop/mapred/GenericMRLoadGenerator.java?rev=690117&r1=690116&r2=690117&view=diff
==============================================================================
---
hadoop/core/trunk/src/test/org/apache/hadoop/mapred/GenericMRLoadGenerator.java
(original)
+++
hadoop/core/trunk/src/test/org/apache/hadoop/mapred/GenericMRLoadGenerator.java
Thu Aug 28 23:16:07 2008
@@ -333,7 +333,7 @@
}
}
- static class SampleMapper<K extends WritableComparable, V extends Writable>
+ public static class SampleMapper<K extends WritableComparable, V extends
Writable>
extends SampleMapReduceBase<K,V> implements Mapper<K,V,K,V> {
public void configure(JobConf job) {
@@ -349,7 +349,7 @@
}
- static class SampleReducer<K extends WritableComparable, V extends Writable>
+ public static class SampleReducer<K extends WritableComparable, V extends
Writable>
extends SampleMapReduceBase<K,V> implements Reducer<K,V,K,V> {
public void configure(JobConf job) {
