change back to SequenceFile.Writer
git-svn-id: https://hyracks.googlecode.com/svn/branches/fullstack_genomix@3010 123451ca-8445-de46-9d55-352943316053
diff --git a/genomix/genomix-core/src/main/java/edu/uci/ics/genomix/dataflow/KMerSequenceWriterFactory.java b/genomix/genomix-core/src/main/java/edu/uci/ics/genomix/dataflow/KMerSequenceWriterFactory.java
index 88ae57d..2615fca 100644
--- a/genomix/genomix-core/src/main/java/edu/uci/ics/genomix/dataflow/KMerSequenceWriterFactory.java
+++ b/genomix/genomix-core/src/main/java/edu/uci/ics/genomix/dataflow/KMerSequenceWriterFactory.java
@@ -4,6 +4,10 @@
import java.io.IOException;
import org.apache.hadoop.fs.FSDataOutputStream;
+import org.apache.hadoop.io.BytesWritable;
+import org.apache.hadoop.io.SequenceFile;
+import org.apache.hadoop.io.SequenceFile.CompressionType;
+import org.apache.hadoop.io.SequenceFile.Writer;
import org.apache.hadoop.mapred.JobConf;
import edu.uci.ics.genomix.dataflow.util.NonSyncWriter;
@@ -30,8 +34,8 @@
}
ConfFactory cf;
- //Writer writer = null;
- NonSyncWriter writer = null;
+ Writer writer = null;
+// NonSyncWriter writer = null;
KmerCountValue reEnterCount = new KmerCountValue();
/**
@@ -42,10 +46,10 @@
throws HyracksDataException {
try {
if (writer == null) {
- writer = new NonSyncWriter((FSDataOutputStream) output);
-// writer = SequenceFile.createWriter(cf.getConf(),
-// (FSDataOutputStream) output, BytesWritable.class,
-// BytesWritable.class, CompressionType.NONE, null);
+// writer = new NonSyncWriter((FSDataOutputStream) output);
+ writer = SequenceFile.createWriter(cf.getConf(),
+ (FSDataOutputStream) output, BytesWritable.class,
+ BytesWritable.class, CompressionType.NONE, null);
}
byte[] kmer = tuple.getFieldData(0);
int keyStart = tuple.getFieldStart(0);