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));