You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mrunit.apache.org by es...@apache.org on 2011/05/12 00:17:35 UTC
svn commit: r1102112 - in /incubator/mrunit/trunk: ./ ivy/
src/java/org/apache/hadoop/mrunit/
src/java/org/apache/hadoop/mrunit/mapreduce/
src/java/org/apache/hadoop/mrunit/mapreduce/mock/
src/java/org/apache/hadoop/mrunit/mock/ src/java/org/apache/had...
Author: esammer
Date: Wed May 11 22:17:32 2011
New Revision: 1102112
URL: http://svn.apache.org/viewvc?rev=1102112&view=rev
Log:
MRUNIT-1: Port build system to Maven
MRUNIT-6: Reverse MAPREDUCE-954 in trunk
These were rolled into a single commit only because MRUNIT-6 couldn't be tested
on trunk as the ant build was broken since extracting from hadoop trunk. I
won't be combining patches for different JIRAs in the future.
Added:
incubator/mrunit/trunk/pom.xml
incubator/mrunit/trunk/src/main/
incubator/mrunit/trunk/src/main/java/
incubator/mrunit/trunk/src/main/java/org/
incubator/mrunit/trunk/src/main/java/org/apache/
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/MapDriver.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/MapDriver.java
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/MapDriverBase.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/MapDriverBase.java
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/MapReduceDriver.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/MapReduceDriver.java
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/MapReduceDriverBase.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/MapReduceDriverBase.java
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/PipelineMapReduceDriver.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/PipelineMapReduceDriver.java
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/ReduceDriver.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/ReduceDriver.java
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/ReduceDriverBase.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/ReduceDriverBase.java
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/TestDriver.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/TestDriver.java
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/MapDriver.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/MapDriver.java
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/MapReduceDriver.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/MapReduceDriver.java
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/ReduceDriver.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/ReduceDriver.java
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockInputSplit.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/mock/MockInputSplit.java
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockMapContextWrapper.java
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockOutputCommitter.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/mock/MockOutputCommitter.java
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockRawKeyValueIterator.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/mock/MockRawKeyValueIterator.java
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockReduceContextWrapper.java
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockReporter.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/mock/MockReporter.java
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mock/
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mock/MockInputSplit.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mock/MockInputSplit.java
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mock/MockMapContext.java
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mock/MockOutputCollector.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mock/MockOutputCollector.java
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mock/MockReporter.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mock/MockReporter.java
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/package.html
- copied, changed from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/package.html
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/testutil/
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/testutil/ExtendedAssert.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/testutil/ExtendedAssert.java
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/types/
incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/types/Pair.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/types/Pair.java
incubator/mrunit/trunk/src/test/java/
incubator/mrunit/trunk/src/test/java/org/
incubator/mrunit/trunk/src/test/java/org/apache/
incubator/mrunit/trunk/src/test/java/org/apache/hadoop/
incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/
incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/AllTests.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/AllTests.java
incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestCounters.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestCounters.java
incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestExample.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestExample.java
incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestMapDriver.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestMapDriver.java
incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestMapReduceDriver.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestMapReduceDriver.java
incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestPipelineMapReduceDriver.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestPipelineMapReduceDriver.java
incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestReduceDriver.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestReduceDriver.java
incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestTestDriver.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestTestDriver.java
incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/
incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/AllTests.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mapreduce/AllTests.java
incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestCounters.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mapreduce/TestCounters.java
incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestMapDriver.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mapreduce/TestMapDriver.java
incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestMapReduceDriver.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mapreduce/TestMapReduceDriver.java
incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestReduceDriver.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mapreduce/TestReduceDriver.java
incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mock/
incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mock/TestMockOutputCollector.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mock/TestMockOutputCollector.java
incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mock/TestMockReporter.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mock/TestMockReporter.java
incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/types/
incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/types/AllTests.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/types/AllTests.java
incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/types/TestPair.java
- copied, changed from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/types/TestPair.java
Removed:
incubator/mrunit/trunk/build.xml
incubator/mrunit/trunk/ivy.xml
incubator/mrunit/trunk/ivy/libraries.properties
incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/MapDriver.java
incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/MapDriverBase.java
incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/MapReduceDriver.java
incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/MapReduceDriverBase.java
incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/PipelineMapReduceDriver.java
incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/ReduceDriver.java
incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/ReduceDriverBase.java
incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/TestDriver.java
incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/MapDriver.java
incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/MapReduceDriver.java
incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/ReduceDriver.java
incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/mock/MockInputSplit.java
incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/mock/MockMapContext.java
incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/mock/MockOutputCommitter.java
incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/mock/MockRawKeyValueIterator.java
incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/mock/MockReduceContext.java
incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/mock/MockReporter.java
incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mock/MockInputSplit.java
incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mock/MockOutputCollector.java
incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mock/MockReporter.java
incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/package.html
incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/testutil/ExtendedAssert.java
incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/types/Pair.java
incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/AllTests.java
incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestCounters.java
incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestExample.java
incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestMapDriver.java
incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestMapReduceDriver.java
incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestPipelineMapReduceDriver.java
incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestReduceDriver.java
incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestTestDriver.java
incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mapreduce/AllTests.java
incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mapreduce/TestCounters.java
incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mapreduce/TestMapDriver.java
incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mapreduce/TestMapReduceDriver.java
incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mapreduce/TestReduceDriver.java
incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mock/TestMockOutputCollector.java
incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mock/TestMockReporter.java
incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/types/AllTests.java
incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/types/TestPair.java
Added: incubator/mrunit/trunk/pom.xml
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/pom.xml?rev=1102112&view=auto
==============================================================================
--- incubator/mrunit/trunk/pom.xml (added)
+++ incubator/mrunit/trunk/pom.xml Wed May 11 22:17:32 2011
@@ -0,0 +1,105 @@
+<!--
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ -->
+
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+
+ <modelVersion>4.0.0</modelVersion>
+ <groupId>org.apache.mrunit</groupId>
+ <artifactId>mrunit</artifactId>
+ <version>0.5.0</version>
+ <name>MRUnit</name>
+
+ <properties>
+ <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+ </properties>
+
+ <licenses>
+ <license>
+ <name>The Apache Software License, Version 2.0</name>
+ <url>http://www.apache.org/licenses/LICENSE-2.0.txt</url>
+ </license>
+ </licenses>
+
+ <build>
+
+ <plugins>
+
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-compiler-plugin</artifactId>
+ <version>2.3.2</version>
+ <configuration>
+ <source>1.6</source>
+ <target>1.6</target>
+ </configuration>
+ </plugin>
+
+ </plugins>
+
+ </build>
+
+ <dependencies>
+
+ <dependency>
+ <groupId>junit</groupId>
+ <artifactId>junit</artifactId>
+ <version>4.8.1</version>
+ </dependency>
+
+ <dependency>
+ <groupId>commons-logging</groupId>
+ <artifactId>commons-logging</artifactId>
+ <version>1.1.1</version>
+ </dependency>
+
+ <dependency>
+ <groupId>log4j</groupId>
+ <artifactId>log4j</artifactId>
+ <version>1.2.15</version>
+
+ <exclusions>
+ <exclusion>
+ <groupId>com.sun.jdmk</groupId>
+ <artifactId>jmxtools</artifactId>
+ </exclusion>
+ <exclusion>
+ <groupId>com.sun.jmx</groupId>
+ <artifactId>jmxri</artifactId>
+ </exclusion>
+ <exclusion>
+ <groupId>javax.jms</groupId>
+ <artifactId>jms</artifactId>
+ </exclusion>
+ <exclusion>
+ <groupId>javax.mail</groupId>
+ <artifactId>mail</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.hadoop</groupId>
+ <artifactId>hadoop-core</artifactId>
+ <version>0.20.2</version>
+ </dependency>
+
+ </dependencies>
+
+</project>
Copied: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/MapDriver.java (from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/MapDriver.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/MapDriver.java?p2=incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/MapDriver.java&p1=incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/MapDriver.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/MapDriverBase.java (from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/MapDriverBase.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/MapDriverBase.java?p2=incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/MapDriverBase.java&p1=incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/MapDriverBase.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/MapReduceDriver.java (from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/MapReduceDriver.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/MapReduceDriver.java?p2=incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/MapReduceDriver.java&p1=incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/MapReduceDriver.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/MapReduceDriverBase.java (from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/MapReduceDriverBase.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/MapReduceDriverBase.java?p2=incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/MapReduceDriverBase.java&p1=incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/MapReduceDriverBase.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/PipelineMapReduceDriver.java (from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/PipelineMapReduceDriver.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/PipelineMapReduceDriver.java?p2=incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/PipelineMapReduceDriver.java&p1=incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/PipelineMapReduceDriver.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/ReduceDriver.java (from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/ReduceDriver.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/ReduceDriver.java?p2=incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/ReduceDriver.java&p1=incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/ReduceDriver.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/ReduceDriverBase.java (from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/ReduceDriverBase.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/ReduceDriverBase.java?p2=incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/ReduceDriverBase.java&p1=incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/ReduceDriverBase.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/TestDriver.java (from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/TestDriver.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/TestDriver.java?p2=incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/TestDriver.java&p1=incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/TestDriver.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/MapDriver.java (from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/MapDriver.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/MapDriver.java?p2=incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/MapDriver.java&p1=incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/MapDriver.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
--- incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/MapDriver.java (original)
+++ incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/MapDriver.java Wed May 11 22:17:32 2011
@@ -25,12 +25,12 @@ import java.util.List;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.io.Text;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.mapreduce.Counters;
import org.apache.hadoop.mapreduce.Mapper;
-import org.apache.hadoop.mapreduce.lib.map.WrappedMapper;
import org.apache.hadoop.mrunit.MapDriverBase;
-import org.apache.hadoop.mrunit.mapreduce.mock.MockMapContext;
+import org.apache.hadoop.mrunit.mapreduce.mock.MockMapContextWrapper;
import org.apache.hadoop.mrunit.types.Pair;
/**
@@ -193,10 +193,11 @@ public class MapDriver<K1, V1, K2, V2> e
inputs.add(new Pair<K1, V1>(inputKey, inputVal));
try {
- MockMapContext<K1, V1, K2, V2> context =
- new MockMapContext<K1, V1, K2, V2>(configuration, inputs, getCounters());
+ MockMapContextWrapper<K1, V1, K2, V2> wrapper = new MockMapContextWrapper();
+ MockMapContextWrapper<K1, V1, K2, V2>.MockMapContext context =
+ wrapper.getMockContext(inputs, getCounters());
- myMapper.run(new WrappedMapper<K1, V1, K2, V2>().getMapContext(context));
+ myMapper.run(context);
return context.getOutputs();
} catch (InterruptedException ie) {
throw new IOException(ie);
Copied: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/MapReduceDriver.java (from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/MapReduceDriver.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/MapReduceDriver.java?p2=incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/MapReduceDriver.java&p1=incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/MapReduceDriver.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/ReduceDriver.java (from r1085864, incubator/mrunit/trunk/src/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?p2=incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/ReduceDriver.java&p1=incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/ReduceDriver.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
--- incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/ReduceDriver.java (original)
+++ incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/ReduceDriver.java Wed May 11 22:17:32 2011
@@ -25,12 +25,12 @@ import java.util.List;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.io.Text;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.mapreduce.Counters;
import org.apache.hadoop.mapreduce.Reducer;
-import org.apache.hadoop.mapreduce.lib.reduce.WrappedReducer;
import org.apache.hadoop.mrunit.ReduceDriverBase;
-import org.apache.hadoop.mrunit.mapreduce.mock.MockReduceContext;
+import org.apache.hadoop.mrunit.mapreduce.mock.MockReduceContextWrapper;
import org.apache.hadoop.mrunit.types.Pair;
/**
@@ -198,9 +198,11 @@ public class ReduceDriver<K1, V1, K2, V2
inputs.add(new Pair<K1, List<V1>>(inputKey, inputValues));
try {
- MockReduceContext<K1, V1, K2, V2> context =
- new MockReduceContext<K1, V1, K2, V2>(configuration, inputs, getCounters());
- myReducer.run(new WrappedReducer<K1, V1, K2, V2>().getReducerContext(context));
+ MockReduceContextWrapper<K1, V1, K2, V2> wrapper = new MockReduceContextWrapper();
+ MockReduceContextWrapper<K1, V1, K2, V2>.MockReduceContext context =
+ wrapper.getMockContext(inputs, getCounters());
+
+ myReducer.run(context);
return context.getOutputs();
} catch (InterruptedException ie) {
throw new IOException(ie);
Copied: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockInputSplit.java (from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/mock/MockInputSplit.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockInputSplit.java?p2=incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockInputSplit.java&p1=incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/mock/MockInputSplit.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Added: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockMapContextWrapper.java
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockMapContextWrapper.java?rev=1102112&view=auto
==============================================================================
--- incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockMapContextWrapper.java (added)
+++ incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockMapContextWrapper.java Wed May 11 22:17:32 2011
@@ -0,0 +1,121 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.hadoop.mrunit.mapreduce.mock;
+
+import java.io.IOException;
+import java.util.Iterator;
+import java.util.List;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.mapreduce.Counters;
+import org.apache.hadoop.mapreduce.InputSplit;
+import org.apache.hadoop.mapreduce.Mapper;
+import org.apache.hadoop.mapreduce.TaskAttemptID;
+import org.apache.hadoop.mrunit.mock.MockOutputCollector;
+import org.apache.hadoop.mrunit.types.Pair;
+
+/**
+ * o.a.h.mapreduce.Mapper.map() expects to use a Mapper.Context
+ * object as a parameter. We want to override the functionality
+ * of a lot of Context to have it send the results back to us, etc.
+ * But since Mapper.Context is an inner class of Mapper, we need to
+ * put any subclasses of Mapper.Context in a subclass of Mapper.
+ *
+ * This wrapper class exists for that purpose.
+ */
+public class MockMapContextWrapper<KEYIN, VALUEIN, KEYOUT, VALUEOUT>
+ extends Mapper<KEYIN, VALUEIN, KEYOUT, VALUEOUT> {
+
+ public static final Log LOG = LogFactory.getLog(MockMapContextWrapper.class);
+
+ /**
+ * Mock context instance that provides input to and receives output from
+ * the Mapper instance under test.
+ */
+ public class MockMapContext extends Mapper<KEYIN, VALUEIN, KEYOUT, VALUEOUT>.Context {
+
+ private Iterator<Pair<KEYIN, VALUEIN>> inputIter;
+ private Pair<KEYIN, VALUEIN> curInput;
+ private MockOutputCollector<KEYOUT, VALUEOUT> output;
+
+ public MockMapContext(final List<Pair<KEYIN, VALUEIN>> in, final Counters counters)
+ throws IOException, InterruptedException {
+
+ super(new Configuration(),
+ new TaskAttemptID("mrunit-jt", 0, true, 0, 0),
+ null, null, new MockOutputCommitter(), new MockReporter(counters), null);
+ this.inputIter = in.iterator();
+ this.output = new MockOutputCollector<KEYOUT, VALUEOUT>();
+ }
+
+ @Override
+ public InputSplit getInputSplit() {
+ return new MockInputSplit();
+ }
+
+ @Override
+ public KEYIN getCurrentKey() {
+ return curInput.getFirst();
+ }
+
+ @Override
+ public VALUEIN getCurrentValue() {
+ return curInput.getSecond();
+ }
+
+ @Override
+ public boolean nextKeyValue() throws IOException {
+ if (this.inputIter.hasNext()) {
+ this.curInput = this.inputIter.next();
+ return true;
+ } else {
+ return false;
+ }
+ }
+
+ public void write(KEYOUT key, VALUEOUT value) throws IOException {
+ output.collect(key, value);
+ }
+
+ @Override
+ /** This method does nothing in the mock version. */
+ public void progress() {
+ }
+
+ @Override
+ /** This method does nothing in the mock version. */
+ public void setStatus(String status) {
+ }
+
+ /**
+ * @return the outputs from the MockOutputCollector back to
+ * the test harness.
+ */
+ public List<Pair<KEYOUT, VALUEOUT>> getOutputs() {
+ return output.getOutputs();
+ }
+ }
+
+ public MockMapContext getMockContext(List<Pair<KEYIN, VALUEIN>> inputs, Counters counters)
+ throws IOException, InterruptedException {
+ return new MockMapContext(inputs, counters);
+ }
+}
Copied: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockOutputCommitter.java (from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/mock/MockOutputCommitter.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockOutputCommitter.java?p2=incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockOutputCommitter.java&p1=incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/mock/MockOutputCommitter.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockRawKeyValueIterator.java (from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/mock/MockRawKeyValueIterator.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockRawKeyValueIterator.java?p2=incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockRawKeyValueIterator.java&p1=incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/mock/MockRawKeyValueIterator.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Added: 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=1102112&view=auto
==============================================================================
--- incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockReduceContextWrapper.java (added)
+++ incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockReduceContextWrapper.java Wed May 11 22:17:32 2011
@@ -0,0 +1,185 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.hadoop.mrunit.mapreduce.mock;
+
+import java.io.IOException;
+import java.util.Iterator;
+import java.util.List;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.io.Text;
+import org.apache.hadoop.mapreduce.Counters;
+import org.apache.hadoop.mapreduce.ReduceContext;
+import org.apache.hadoop.mapreduce.Reducer;
+import org.apache.hadoop.mapreduce.TaskAttemptID;
+import org.apache.hadoop.mrunit.mock.MockOutputCollector;
+import org.apache.hadoop.mrunit.types.Pair;
+
+/**
+ * o.a.h.mapreduce.Reducer.reduce() expects to use a Reducer.Context
+ * object as a parameter. We want to override the functionality
+ * of a lot of Context to have it send the results back to us, etc.
+ * But since Reducer.Context is an inner class of Reducer, we need to
+ * put any subclasses of Reducer.Context in a subclass of Reducer.
+ *
+ * This wrapper class exists for that purpose.
+ */
+public class MockReduceContextWrapper<KEYIN, VALUEIN, KEYOUT, VALUEOUT>
+ extends Reducer<KEYIN, VALUEIN, KEYOUT, VALUEOUT> {
+
+ public static final Log LOG = LogFactory.getLog(MockReduceContextWrapper.class);
+
+ /**
+ * Mock context instance that provides input to and receives output from
+ * the Mapper instance under test.
+ */
+ public class MockReduceContext extends Reducer<KEYIN, VALUEIN, KEYOUT, VALUEOUT>.Context {
+
+ // The iterator over the input key, list(val).
+ private Iterator<Pair<KEYIN, List<VALUEIN>>> inputIter;
+
+ // The current key and list of values.
+ private KEYIN curKey;
+ private InspectableIterable curValueIterable;
+
+ private MockOutputCollector<KEYOUT, VALUEOUT> output;
+
+ public MockReduceContext(final List<Pair<KEYIN, List<VALUEIN>>> in, final Counters counters)
+ throws IOException, InterruptedException {
+
+ super(new Configuration(),
+ new TaskAttemptID("mrunit-jt", 0, false, 0, 0),
+ new MockRawKeyValueIterator(), null, null, null,
+ new MockOutputCommitter(), new MockReporter(counters), null,
+ (Class) Text.class, (Class) Text.class);
+ this.inputIter = in.iterator();
+ this.output = new MockOutputCollector<KEYOUT, VALUEOUT>();
+ }
+
+
+ /**
+ * A private iterable/iterator implementation that wraps around the
+ * underlying iterable/iterator used by the input value list. This
+ * memorizes the last value we saw so that we can return it in getCurrentValue().
+ */
+ private class InspectableIterable implements Iterable<VALUEIN> {
+ private Iterable<VALUEIN> base;
+ private VALUEIN lastVal;
+
+ public InspectableIterable(final Iterable<VALUEIN> baseCollection) {
+ this.base = baseCollection;
+ }
+
+ public Iterator<VALUEIN> iterator() {
+ return new InspectableIterator(this.base.iterator());
+ }
+
+ public VALUEIN getLastVal() {
+ return lastVal;
+ }
+
+ private class InspectableIterator
+ extends ReduceContext<KEYIN, VALUEIN, KEYOUT, VALUEOUT>.ValueIterator
+ implements Iterator<VALUEIN> {
+ private Iterator<VALUEIN> iter;
+ public InspectableIterator(final Iterator<VALUEIN> baseIter) {
+ iter = baseIter;
+ }
+
+ public VALUEIN next() {
+ InspectableIterable.this.lastVal = iter.next();
+ return InspectableIterable.this.lastVal;
+ }
+
+ public boolean hasNext() {
+ return iter.hasNext();
+ }
+
+ public void remove() {
+ iter.remove();
+ }
+ }
+ }
+
+ @Override
+ public boolean nextKey() {
+ if (inputIter.hasNext()) {
+ // Advance to the next key and list of values
+ Pair<KEYIN, List<VALUEIN>> p = inputIter.next();
+ curKey = p.getFirst();
+
+ // Reset the value iterator
+ curValueIterable = new InspectableIterable(p.getSecond());
+ return true;
+ } else {
+ return false;
+ }
+ }
+
+ @Override
+ public boolean nextKeyValue() {
+ return nextKey();
+ }
+
+ @Override
+ public KEYIN getCurrentKey() {
+ return curKey;
+ }
+
+ @Override
+ public VALUEIN getCurrentValue() {
+ return curValueIterable.getLastVal();
+ }
+
+ @Override
+ public Iterable<VALUEIN> getValues() {
+ return curValueIterable;
+ }
+
+ public void write(KEYOUT key, VALUEOUT value) throws IOException {
+ output.collect(key, value);
+ }
+
+ @Override
+ /** This method does nothing in the mock version. */
+ public void progress() {
+ }
+
+ @Override
+ /** This method does nothing in the mock version. */
+ public void setStatus(String status) {
+ }
+
+ /**
+ * @return the outputs from the MockOutputCollector back to
+ * the test harness.
+ */
+ public List<Pair<KEYOUT, VALUEOUT>> getOutputs() {
+ return output.getOutputs();
+ }
+ }
+
+ public MockReduceContext getMockContext(List<Pair<KEYIN, List<VALUEIN>>> inputs,
+ Counters counters)
+ throws IOException, InterruptedException {
+ return new MockReduceContext(inputs, counters);
+ }
+}
Copied: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockReporter.java (from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/mock/MockReporter.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockReporter.java?p2=incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mapreduce/mock/MockReporter.java&p1=incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mapreduce/mock/MockReporter.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mock/MockInputSplit.java (from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mock/MockInputSplit.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mock/MockInputSplit.java?p2=incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mock/MockInputSplit.java&p1=incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mock/MockInputSplit.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Added: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mock/MockMapContext.java
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mock/MockMapContext.java?rev=1102112&view=auto
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mock/MockOutputCollector.java (from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mock/MockOutputCollector.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mock/MockOutputCollector.java?p2=incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mock/MockOutputCollector.java&p1=incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mock/MockOutputCollector.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mock/MockReporter.java (from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mock/MockReporter.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mock/MockReporter.java?p2=incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/mock/MockReporter.java&p1=incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/mock/MockReporter.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/package.html (from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/package.html)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/package.html?p2=incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/package.html&p1=incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/package.html&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/testutil/ExtendedAssert.java (from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/testutil/ExtendedAssert.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/testutil/ExtendedAssert.java?p2=incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/testutil/ExtendedAssert.java&p1=incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/testutil/ExtendedAssert.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/types/Pair.java (from r1085864, incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/types/Pair.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/types/Pair.java?p2=incubator/mrunit/trunk/src/main/java/org/apache/hadoop/mrunit/types/Pair.java&p1=incubator/mrunit/trunk/src/java/org/apache/hadoop/mrunit/types/Pair.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/AllTests.java (from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/AllTests.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/AllTests.java?p2=incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/AllTests.java&p1=incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/AllTests.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestCounters.java (from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestCounters.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestCounters.java?p2=incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestCounters.java&p1=incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestCounters.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestExample.java (from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestExample.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestExample.java?p2=incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestExample.java&p1=incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestExample.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestMapDriver.java (from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestMapDriver.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestMapDriver.java?p2=incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestMapDriver.java&p1=incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestMapDriver.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestMapReduceDriver.java (from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestMapReduceDriver.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestMapReduceDriver.java?p2=incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestMapReduceDriver.java&p1=incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestMapReduceDriver.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestPipelineMapReduceDriver.java (from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestPipelineMapReduceDriver.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestPipelineMapReduceDriver.java?p2=incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestPipelineMapReduceDriver.java&p1=incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestPipelineMapReduceDriver.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestReduceDriver.java (from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestReduceDriver.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestReduceDriver.java?p2=incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestReduceDriver.java&p1=incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestReduceDriver.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestTestDriver.java (from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestTestDriver.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestTestDriver.java?p2=incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/TestTestDriver.java&p1=incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/TestTestDriver.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/AllTests.java (from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mapreduce/AllTests.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/AllTests.java?p2=incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/AllTests.java&p1=incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mapreduce/AllTests.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestCounters.java (from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mapreduce/TestCounters.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestCounters.java?p2=incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestCounters.java&p1=incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mapreduce/TestCounters.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestMapDriver.java (from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mapreduce/TestMapDriver.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestMapDriver.java?p2=incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestMapDriver.java&p1=incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mapreduce/TestMapDriver.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestMapReduceDriver.java (from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mapreduce/TestMapReduceDriver.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestMapReduceDriver.java?p2=incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestMapReduceDriver.java&p1=incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mapreduce/TestMapReduceDriver.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestReduceDriver.java (from r1085864, incubator/mrunit/trunk/src/test/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?p2=incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mapreduce/TestReduceDriver.java&p1=incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mapreduce/TestReduceDriver.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mock/TestMockOutputCollector.java (from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mock/TestMockOutputCollector.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mock/TestMockOutputCollector.java?p2=incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mock/TestMockOutputCollector.java&p1=incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mock/TestMockOutputCollector.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mock/TestMockReporter.java (from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mock/TestMockReporter.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mock/TestMockReporter.java?p2=incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/mock/TestMockReporter.java&p1=incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/mock/TestMockReporter.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/types/AllTests.java (from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/types/AllTests.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/types/AllTests.java?p2=incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/types/AllTests.java&p1=incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/types/AllTests.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)
Copied: incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/types/TestPair.java (from r1085864, incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/types/TestPair.java)
URL: http://svn.apache.org/viewvc/incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/types/TestPair.java?p2=incubator/mrunit/trunk/src/test/java/org/apache/hadoop/mrunit/types/TestPair.java&p1=incubator/mrunit/trunk/src/test/org/apache/hadoop/mrunit/types/TestPair.java&r1=1085864&r2=1102112&rev=1102112&view=diff
==============================================================================
(empty)