fix outputKmerFactory racing problem
diff --git a/genomix/genomix-hyracks/src/main/java/edu/uci/ics/genomix/hyracks/dataflow/io/KMerTextWriterFactory.java b/genomix/genomix-hyracks/src/main/java/edu/uci/ics/genomix/hyracks/dataflow/io/KMerTextWriterFactory.java
index f614846..7ea065d 100644
--- a/genomix/genomix-hyracks/src/main/java/edu/uci/ics/genomix/hyracks/dataflow/io/KMerTextWriterFactory.java
+++ b/genomix/genomix-hyracks/src/main/java/edu/uci/ics/genomix/hyracks/dataflow/io/KMerTextWriterFactory.java
@@ -33,15 +33,15 @@
*
*/
private static final long serialVersionUID = 1L;
- private KmerBytesWritable kmer;
- private PositionListWritable plist;
-
+
+ private final int kmerSize;
public KMerTextWriterFactory(int k) {
- kmer = new KmerBytesWritable(k);
- plist = new PositionListWritable();
+ kmerSize =k;
}
public class TupleWriter implements ITupleWriter {
+ private KmerBytesWritable kmer = new KmerBytesWritable(kmerSize);
+ private PositionListWritable plist = new PositionListWritable();
@Override
public void write(DataOutput output, ITupleReference tuple) throws HyracksDataException {
try {