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