You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nutch.apache.org by cu...@apache.org on 2005/10/18 23:06:14 UTC

svn commit: r326245 - in /lucene/nutch/branches/mapred/src/test/org/apache/nutch/mapred: TestSequenceFileInputFormat.java TestTextInputFormat.java

Author: cutting
Date: Tue Oct 18 14:06:12 2005
New Revision: 326245

URL: http://svn.apache.org/viewcvs?rev=326245&view=rev
Log:
Consistently use NutchFileSystem API so that checksum files are correctly handled.

Modified:
    lucene/nutch/branches/mapred/src/test/org/apache/nutch/mapred/TestSequenceFileInputFormat.java
    lucene/nutch/branches/mapred/src/test/org/apache/nutch/mapred/TestTextInputFormat.java

Modified: lucene/nutch/branches/mapred/src/test/org/apache/nutch/mapred/TestSequenceFileInputFormat.java
URL: http://svn.apache.org/viewcvs/lucene/nutch/branches/mapred/src/test/org/apache/nutch/mapred/TestSequenceFileInputFormat.java?rev=326245&r1=326244&r2=326245&view=diff
==============================================================================
--- lucene/nutch/branches/mapred/src/test/org/apache/nutch/mapred/TestSequenceFileInputFormat.java (original)
+++ lucene/nutch/branches/mapred/src/test/org/apache/nutch/mapred/TestSequenceFileInputFormat.java Tue Oct 18 14:06:12 2005
@@ -44,11 +44,11 @@
     //LOG.info("seed = "+seed);
     Random random = new Random(seed);
 
-    dir.mkdirs();
-    File[] files = dir.listFiles();
+    fs.mkdirs(dir);
+    File[] files = fs.listFiles(dir);
     if (files != null) {
       for (int i = 0; i < files.length; i++) {
-        files[i].delete();
+        fs.delete(files[i]);
       }
     }
 
@@ -61,7 +61,7 @@
       //LOG.info("creating; entries = " + length);
 
       // create a file with length entries
-      file.delete();
+      fs.delete(file);
       SequenceFile.Writer writer =
         new SequenceFile.Writer(fs, file.toString(),
                                 IntWritable.class, BytesWritable.class);

Modified: lucene/nutch/branches/mapred/src/test/org/apache/nutch/mapred/TestTextInputFormat.java
URL: http://svn.apache.org/viewcvs/lucene/nutch/branches/mapred/src/test/org/apache/nutch/mapred/TestTextInputFormat.java?rev=326245&r1=326244&r2=326245&view=diff
==============================================================================
--- lucene/nutch/branches/mapred/src/test/org/apache/nutch/mapred/TestTextInputFormat.java (original)
+++ lucene/nutch/branches/mapred/src/test/org/apache/nutch/mapred/TestTextInputFormat.java Tue Oct 18 14:06:12 2005
@@ -44,11 +44,11 @@
     //LOG.info("seed = "+seed);
     Random random = new Random(seed);
 
-    dir.mkdirs();
-    File[] files = dir.listFiles();
+    fs.mkdirs(dir);
+    File[] files = fs.listFiles(dir);
     if (files != null) {
       for (int i = 0; i < files.length; i++) {
-        files[i].delete();
+        fs.delete(files[i]);
       }
     }
 
@@ -61,8 +61,8 @@
       //LOG.info("creating; entries = " + length);
 
       // create a file with length entries
-      file.delete();
-      Writer writer = new FileWriter(file);
+      fs.delete(file);
+      Writer writer = new OutputStreamWriter(fs.create(file));
       try {
         for (int i = 0; i < length; i++) {
           writer.write(Integer.toString(i));