You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by cu...@apache.org on 2006/08/28 21:24:55 UTC

svn commit: r437791 [2/2] - in /lucene/hadoop/trunk: ./ conf/ src/examples/org/apache/hadoop/examples/ src/java/org/apache/hadoop/io/ src/java/org/apache/hadoop/mapred/ src/test/org/apache/hadoop/fs/ src/test/org/apache/hadoop/io/ src/test/org/apache/h...

Modified: lucene/hadoop/trunk/src/test/org/apache/hadoop/record/test/TestMapRed.java
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/src/test/org/apache/hadoop/record/test/TestMapRed.java?rev=437791&r1=437790&r2=437791&view=diff
==============================================================================
--- lucene/hadoop/trunk/src/test/org/apache/hadoop/record/test/TestMapRed.java (original)
+++ lucene/hadoop/trunk/src/test/org/apache/hadoop/record/test/TestMapRed.java Mon Aug 28 12:24:54 2006
@@ -19,6 +19,7 @@
 import org.apache.hadoop.mapred.*;
 import org.apache.hadoop.fs.*;
 import org.apache.hadoop.io.*;
+import org.apache.hadoop.io.SequenceFile.CompressionType;
 import org.apache.hadoop.conf.*;
 import junit.framework.TestCase;
 import java.io.*;
@@ -251,7 +252,9 @@
         fs.mkdirs(randomIns);
 
         File answerkey = new File(randomIns, "answer.key");
-        SequenceFile.Writer out = new SequenceFile.Writer(fs, answerkey.getPath(), RecInt.class, RecInt.class);
+        SequenceFile.Writer out = SequenceFile.createWriter(fs, conf, 
+            new Path(answerkey.getPath()), RecInt.class, RecInt.class, 
+            CompressionType.NONE);
         try {
             for (int i = 0; i < range; i++) {
                 RecInt k = new RecInt();