hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cutt...@apache.org
Subject 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...
Date Mon, 28 Aug 2006 19:24:55 GMT
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();



Mime
View raw message