[Archive-access-cvs] SF.net SVN: archive-access: [1720] trunk/archive-access/projects/wayback/ wayback-mapreduce-prereq/src/main/java/org/archive/wayback/resourceindex/ indexer/hadoop/Driver.java

[<bra...@us...>]

Revision: 1720
          http://archive-access.svn.sourceforge.net/archive-access/?rev=1720&view=rev
Author:   bradtofel
Date:     2007-04-10 18:07:44 -0700 (Tue, 10 Apr 2007)

Log Message:
-----------
Interface: MapClass now implements ARCRecordMapper, so it can be used with current archive-mapred code.

Modified Paths:
--------------
    trunk/archive-access/projects/wayback/wayback-mapreduce-prereq/src/main/java/org/archive/wayback/resourceindex/indexer/hadoop/Driver.java

Modified: trunk/archive-access/projects/wayback/wayback-mapreduce-prereq/src/main/java/org/archive/wayback/resourceindex/indexer/hadoop/Driver.java
===================================================================
--- trunk/archive-access/projects/wayback/wayback-mapreduce-prereq/src/main/java/org/archive/wayback/resourceindex/indexer/hadoop/Driver.java	2007-04-10 23:39:13 UTC (rev 1719)
+++ trunk/archive-access/projects/wayback/wayback-mapreduce-prereq/src/main/java/org/archive/wayback/resourceindex/indexer/hadoop/Driver.java	2007-04-11 01:07:44 UTC (rev 1720)
@@ -25,6 +25,7 @@
 import org.apache.hadoop.util.ReflectionUtils;
 import org.archive.io.arc.ARCRecord;
 import org.archive.mapred.ARCMapRunner;
+import org.archive.mapred.ARCRecordMapper;
 import org.archive.wayback.resourceindex.indexer.ArcIndexer;
 
 /**
@@ -43,7 +44,7 @@
 	 * @author brad
 	 * @version $Date$, $Revision$
 	 */
-	public static class MapClass extends MapReduceBase implements Mapper {
+	public static class MapClass extends MapReduceBase implements ARCRecordMapper {
 
 		private Text outKey = new Text();
 		private Text outValue = new Text("");
@@ -61,6 +62,8 @@
 				e.printStackTrace();
 			}
 		}
+		public void onARCOpen() throws IOException {}
+		public void onARCClose() throws IOException {}
 	}
 
 	static void printUsage() {


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.