| commit | 3a0b4f2ae4c82795f26c352510d8d1b4d008873c | [log] [tgz] |
|---|---|---|
| author | Nan Zhang <zhangnan2920214@gmail.com> | Fri Jul 26 14:37:24 2013 -0700 |
| committer | Nan Zhang <zhangnan2920214@gmail.com> | Fri Jul 26 14:37:24 2013 -0700 |
| tree | 3217ba334c1c1784666ffd81a2566a8e2aa149e5 | |
| parent | a660b8b97799ea01e27271063668c113ccb86873 [diff] |
fix key-value parser bug
diff --git a/genomix/genomix-hyracks/src/main/java/edu/uci/ics/genomix/hyracks/newgraph/dataflow/ReadsKeyValueParserFactory.java b/genomix/genomix-hyracks/src/main/java/edu/uci/ics/genomix/hyracks/newgraph/dataflow/ReadsKeyValueParserFactory.java index 1b123f1..b101312 100644 --- a/genomix/genomix-hyracks/src/main/java/edu/uci/ics/genomix/hyracks/newgraph/dataflow/ReadsKeyValueParserFactory.java +++ b/genomix/genomix-hyracks/src/main/java/edu/uci/ics/genomix/hyracks/newgraph/dataflow/ReadsKeyValueParserFactory.java
@@ -82,8 +82,8 @@ private PositionWritable nodeId = new PositionWritable(); private PositionListWritable nodeIdList = new PositionListWritable(); - private KmerListWritable edgeListForPreKmer = new KmerListWritable(kmerSize);; - private KmerListWritable edgeListForNextKmer = new KmerListWritable(kmerSize);; + private KmerListWritable edgeListForPreKmer = new KmerListWritable(kmerSize); + private KmerListWritable edgeListForNextKmer = new KmerListWritable(kmerSize); private NodeWritable outputNode = new NodeWritable(kmerSize); private KmerBytesWritable preForwardKmer = new KmerBytesWritable(kmerSize);
diff --git a/genomix/genomix-hyracks/src/main/java/edu/uci/ics/genomix/hyracks/newgraph/dataflow/aggregators/AggregateKmerAggregateFactory.java b/genomix/genomix-hyracks/src/main/java/edu/uci/ics/genomix/hyracks/newgraph/dataflow/aggregators/AggregateKmerAggregateFactory.java index d744bbe..cfd582b 100644 --- a/genomix/genomix-hyracks/src/main/java/edu/uci/ics/genomix/hyracks/newgraph/dataflow/aggregators/AggregateKmerAggregateFactory.java +++ b/genomix/genomix-hyracks/src/main/java/edu/uci/ics/genomix/hyracks/newgraph/dataflow/aggregators/AggregateKmerAggregateFactory.java
@@ -44,6 +44,8 @@ this.readLength = readlength; this.kmerSize = k; } + + @Override public IAggregatorDescriptor createAggregator(IHyracksTaskContext ctx, RecordDescriptor inRecordDescriptor, RecordDescriptor outRecordDescriptor, int[] keyFields, int[] keyFieldsInPartialResults)