You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mrunit.apache.org by jd...@apache.org on 2012/09/30 18:15:26 UTC
[3/3] git commit: MRUNIT-101: allow use of real OutputFormats such as
TextOutputFormat instead of the MockOutputCollector/MockContextWrapper
classes
MRUNIT-101: allow use of real OutputFormats such as TextOutputFormat
instead of the MockOutputCollector/MockContextWrapper classes
add javadoc
Project: http://git-wip-us.apache.org/repos/asf/mrunit/repo
Commit: http://git-wip-us.apache.org/repos/asf/mrunit/commit/6a5e5fba
Tree: http://git-wip-us.apache.org/repos/asf/mrunit/tree/6a5e5fba
Diff: http://git-wip-us.apache.org/repos/asf/mrunit/diff/6a5e5fba
Branch: refs/heads/trunk
Commit: 6a5e5fbae2f11d6b8088a9c09a47056c49a4557f
Parents: 9fd77a8
Author: Jim Donofrio <jd...@apache.org>
Authored: Sun Sep 30 11:28:50 2012 -0400
Committer: Jim Donofrio <jd...@apache.org>
Committed: Sun Sep 30 11:28:50 2012 -0400
----------------------------------------------------------------------
.../java/org/apache/hadoop/mrunit/MapDriver.java | 9 +++++++++
.../org/apache/hadoop/mrunit/MapReduceDriver.java | 9 +++++++++
.../org/apache/hadoop/mrunit/ReduceDriver.java | 9 +++++++++
.../apache/hadoop/mrunit/mapreduce/MapDriver.java | 9 +++++++++
.../hadoop/mrunit/mapreduce/MapReduceDriver.java | 9 +++++++++
.../hadoop/mrunit/mapreduce/ReduceDriver.java | 9 +++++++++
6 files changed, 54 insertions(+), 0 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/mrunit/blob/6a5e5fba/src/main/java/org/apache/hadoop/mrunit/MapDriver.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/hadoop/mrunit/MapDriver.java b/src/main/java/org/apache/hadoop/mrunit/MapDriver.java
index fa9cff2..8d44d68 100644
--- a/src/main/java/org/apache/hadoop/mrunit/MapDriver.java
+++ b/src/main/java/org/apache/hadoop/mrunit/MapDriver.java
@@ -106,6 +106,15 @@ public class MapDriver<K1, V1, K2, V2> extends MapDriverBase<K1, V1, K2, V2, Map
return myMapper;
}
+ /**
+ * Configure {@link Mapper} to output with a real {@link OutputFormat}. Set
+ * {@link InputFormat} to read output back in for use with {@link #run()} and
+ * {@link #runTest()}
+ *
+ * @param outputFormatClass
+ * @param inputFormatClass
+ * @return this for fluent style
+ */
@SuppressWarnings("rawtypes")
public MapDriver<K1, V1, K2, V2> withOutputFormat(
final Class<? extends OutputFormat> outputFormatClass,
http://git-wip-us.apache.org/repos/asf/mrunit/blob/6a5e5fba/src/main/java/org/apache/hadoop/mrunit/MapReduceDriver.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/hadoop/mrunit/MapReduceDriver.java b/src/main/java/org/apache/hadoop/mrunit/MapReduceDriver.java
index 2858635..daa72b5 100644
--- a/src/main/java/org/apache/hadoop/mrunit/MapReduceDriver.java
+++ b/src/main/java/org/apache/hadoop/mrunit/MapReduceDriver.java
@@ -186,6 +186,15 @@ public class MapReduceDriver<K1, V1, K2, V2, K3, V3>
return myCombiner;
}
+ /**
+ * Configure {@link Reducer} to output with a real {@link OutputFormat}. Set
+ * {@link InputFormat} to read output back in for use with {@link #run()} and
+ * {@link #runTest()}
+ *
+ * @param outputFormatClass
+ * @param inputFormatClass
+ * @return this for fluent style
+ */
@SuppressWarnings("rawtypes")
public MapReduceDriver<K1, V1, K2, V2, K3, V3> withOutputFormat(
final Class<? extends OutputFormat> outputFormatClass,
http://git-wip-us.apache.org/repos/asf/mrunit/blob/6a5e5fba/src/main/java/org/apache/hadoop/mrunit/ReduceDriver.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/hadoop/mrunit/ReduceDriver.java b/src/main/java/org/apache/hadoop/mrunit/ReduceDriver.java
index 0a456b8..b76f9d0 100644
--- a/src/main/java/org/apache/hadoop/mrunit/ReduceDriver.java
+++ b/src/main/java/org/apache/hadoop/mrunit/ReduceDriver.java
@@ -109,6 +109,15 @@ public class ReduceDriver<K1, V1, K2, V2> extends
return myReducer;
}
+ /**
+ * Configure {@link Reducer} to output with a real {@link OutputFormat}. Set
+ * {@link InputFormat} to read output back in for use with {@link #run()} and
+ * {@link #runTest()}
+ *
+ * @param outputFormatClass
+ * @param inputFormatClass
+ * @return this for fluent style
+ */
@SuppressWarnings("rawtypes")
public ReduceDriver<K1, V1, K2, V2> withOutputFormat(
final Class<? extends OutputFormat> outputFormatClass,
http://git-wip-us.apache.org/repos/asf/mrunit/blob/6a5e5fba/src/main/java/org/apache/hadoop/mrunit/mapreduce/MapDriver.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/hadoop/mrunit/mapreduce/MapDriver.java b/src/main/java/org/apache/hadoop/mrunit/mapreduce/MapDriver.java
index 0bf7577..5b7393b 100644
--- a/src/main/java/org/apache/hadoop/mrunit/mapreduce/MapDriver.java
+++ b/src/main/java/org/apache/hadoop/mrunit/mapreduce/MapDriver.java
@@ -109,6 +109,15 @@ extends MapDriverBase<K1, V1, K2, V2, MapDriver<K1, V1, K2, V2> > implements Con
return this;
}
+ /**
+ * Configure {@link Mapper} to output with a real {@link OutputFormat}. Set
+ * {@link InputFormat} to read output back in for use with {@link #run()} and
+ * {@link #runTest()}
+ *
+ * @param outputFormatClass
+ * @param inputFormatClass
+ * @return this for fluent style
+ */
@SuppressWarnings("rawtypes")
public MapDriver<K1, V1, K2, V2> withOutputFormat(
final Class<? extends OutputFormat> outputFormatClass,
http://git-wip-us.apache.org/repos/asf/mrunit/blob/6a5e5fba/src/main/java/org/apache/hadoop/mrunit/mapreduce/MapReduceDriver.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/hadoop/mrunit/mapreduce/MapReduceDriver.java b/src/main/java/org/apache/hadoop/mrunit/mapreduce/MapReduceDriver.java
index 15408b0..002e6c5 100644
--- a/src/main/java/org/apache/hadoop/mrunit/mapreduce/MapReduceDriver.java
+++ b/src/main/java/org/apache/hadoop/mrunit/mapreduce/MapReduceDriver.java
@@ -184,6 +184,15 @@ public class MapReduceDriver<K1, V1, K2, V2, K3, V3> extends
return this;
}
+ /**
+ * Configure {@link Reducer} to output with a real {@link OutputFormat}. Set
+ * {@link InputFormat} to read output back in for use with {@link #run()} and
+ * {@link #runTest()}
+ *
+ * @param outputFormatClass
+ * @param inputFormatClass
+ * @return this for fluent style
+ */
@SuppressWarnings("rawtypes")
public MapReduceDriver<K1, V1, K2, V2, K3, V3> withOutputFormat(
final Class<? extends OutputFormat> outputFormatClass,
http://git-wip-us.apache.org/repos/asf/mrunit/blob/6a5e5fba/src/main/java/org/apache/hadoop/mrunit/mapreduce/ReduceDriver.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/hadoop/mrunit/mapreduce/ReduceDriver.java b/src/main/java/org/apache/hadoop/mrunit/mapreduce/ReduceDriver.java
index 8bd3734..7fbec80 100644
--- a/src/main/java/org/apache/hadoop/mrunit/mapreduce/ReduceDriver.java
+++ b/src/main/java/org/apache/hadoop/mrunit/mapreduce/ReduceDriver.java
@@ -115,6 +115,15 @@ public class ReduceDriver<K1, V1, K2, V2> extends
return this;
}
+ /**
+ * Configure {@link Reducer} to output with a real {@link OutputFormat}. Set
+ * {@link InputFormat} to read output back in for use with {@link #run()} and
+ * {@link #runTest()}
+ *
+ * @param outputFormatClass
+ * @param inputFormatClass
+ * @return this for fluent style
+ */
@SuppressWarnings("rawtypes")
public ReduceDriver<K1, V1, K2, V2> withOutputFormat(
final Class<? extends OutputFormat> outputFormatClass,