incubator-accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From afu...@apache.org
Subject svn commit: r1241226 - /incubator/accumulo/branches/1.4/src/examples/wikisearch/ingest/src/main/java/org/apache/accumulo/examples/wikisearch/ingest/WikipediaInputFormat.java
Date Mon, 06 Feb 2012 22:35:47 GMT
Author: afuchs
Date: Mon Feb  6 22:35:47 2012
New Revision: 1241226

URL: http://svn.apache.org/viewvc?rev=1241226&view=rev
Log:
ACCUMULO-375 fixed input split problem

Modified:
    incubator/accumulo/branches/1.4/src/examples/wikisearch/ingest/src/main/java/org/apache/accumulo/examples/wikisearch/ingest/WikipediaInputFormat.java

Modified: incubator/accumulo/branches/1.4/src/examples/wikisearch/ingest/src/main/java/org/apache/accumulo/examples/wikisearch/ingest/WikipediaInputFormat.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/examples/wikisearch/ingest/src/main/java/org/apache/accumulo/examples/wikisearch/ingest/WikipediaInputFormat.java?rev=1241226&r1=1241225&r2=1241226&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/examples/wikisearch/ingest/src/main/java/org/apache/accumulo/examples/wikisearch/ingest/WikipediaInputFormat.java
(original)
+++ incubator/accumulo/branches/1.4/src/examples/wikisearch/ingest/src/main/java/org/apache/accumulo/examples/wikisearch/ingest/WikipediaInputFormat.java
Mon Feb  6 22:35:47 2012
@@ -101,7 +101,7 @@ public class WikipediaInputFormat extend
   @Override
   public List<InputSplit> getSplits(JobContext job) throws IOException {
     List<InputSplit> superSplits = super.getSplits(job);
-    List<WikipediaInputSplit> splits = new ArrayList<WikipediaInputSplit>();
+    List<InputSplit> splits = new ArrayList<InputSplit>();
     
     int numGroups = WikipediaConfiguration.getNumGroups(job.getConfiguration());
 
@@ -113,7 +113,7 @@ public class WikipediaInputFormat extend
         splits.add(new WikipediaInputSplit(fileSplit,group));
       }
     }
-    return super.getSplits(job);
+    return splits;
   }
 
   @Override



Mime
View raw message