You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mrunit.apache.org by br...@apache.org on 2011/11/28 18:05:31 UTC
svn commit: r1207456 - in /incubator/mrunit/trunk/src: main/java/org/apache/hadoop/mrunit/mapreduce/ main/java/org/apache/hadoop/mrunit/mapreduce/mock/ test/java/org/apache/hadoop/mrunit/mapreduce/

Author: brock
Date: Mon Nov 28 17:05:30 2011
New Revision: 1207456

URL: http://svn.apache.org/viewvc?rev=1207456&view=rev
Log:
MRUNIT-27: Remove unused variables/imports (2)

Modified:
    incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/ReduceDriver.java
    incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockReduceContextWrapper.java
    incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestReduceDriver.java

Modified: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/ReduceDriver.java
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/ReduceDriver.java?rev=1207456&r1=1207455&r2=1207456&view=diff
==============================================================================
--- incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/ReduceDriver.java (original)
+++ incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/ReduceDriver.java Mon Nov 28 17:05:30 2011
@@ -200,7 +200,7 @@ public class ReduceDriver<K1, V1, K2, V2
       MockReduceContextWrapper<K1, V1, K2, V2> wrapper = 
         new MockReduceContextWrapper<K1, V1, K2, V2>(inputs, getCounters(), getConfiguration());
       Reducer<K1, V1, K2, V2>.Context context = wrapper.getMockContext();
-      myReducer.run(wrapper.getMockContext());
+      myReducer.run(context);
       return wrapper.getOutputs();
     } catch (InterruptedException ie) {
       throw new IOException(ie);

Modified: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockReduceContextWrapper.java
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockReduceContextWrapper.java?rev=1207456&r1=1207455&r2=1207456&view=diff
==============================================================================
--- incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockReduceContextWrapper.java (original)
+++ incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockReduceContextWrapper.java Mon Nov 28 17:05:30 2011
@@ -22,7 +22,6 @@ import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.when;
 
 import java.io.IOException;
-import java.lang.reflect.Constructor;
 import java.util.Iterator;
 import java.util.List;
 

Modified: incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestReduceDriver.java
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestReduceDriver.java?rev=1207456&r1=1207455&r2=1207456&view=diff
==============================================================================
--- incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestReduceDriver.java (original)
+++ incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestReduceDriver.java Mon Nov 28 17:05:30 2011
@@ -233,6 +233,7 @@ public class TestReduceDriver extends Te
    */
   private static class DoubleIterReducer<K, V>
       extends Reducer<K, V, K, LongWritable> {
+    @SuppressWarnings("unused") 
     public void reduce(K key, Iterable<V> values, Context c)
         throws IOException, InterruptedException {
       long count = 0;