commit | 326f573facf9000e92aa20520cea437a6f3deade | [log] [tgz] |
---|---|---|
author | AnbangX <anbangx@anbangx-Ubuntu.(none)> | Fri May 03 16:38:12 2013 -0700 |
committer | AnbangX <anbangx@anbangx-Ubuntu.(none)> | Fri May 03 16:38:12 2013 -0700 |
tree | 2f302c8dafaee83ce3b786f8baa7b7f8e6f0aabe | |
parent | df7c076f7b0ccf4f07396996a2a443d49d90b99c [diff] |
change outputformat for test
diff --git a/genomix/genomix-pregelix/src/main/java/edu/uci/ics/genomix/pregelix/format/NaiveAlgorithmForPathMergeOutputFormat.java b/genomix/genomix-pregelix/src/main/java/edu/uci/ics/genomix/pregelix/format/NaiveAlgorithmForPathMergeOutputFormat.java index 7ef45de..3dd0f2f 100644 --- a/genomix/genomix-pregelix/src/main/java/edu/uci/ics/genomix/pregelix/format/NaiveAlgorithmForPathMergeOutputFormat.java +++ b/genomix/genomix-pregelix/src/main/java/edu/uci/ics/genomix/pregelix/format/NaiveAlgorithmForPathMergeOutputFormat.java
@@ -37,7 +37,8 @@ @Override public void writeVertex(Vertex<KmerBytesWritable, ValueStateWritable, NullWritable, ?> vertex) throws IOException, InterruptedException { - if(vertex.getVertexValue().getState() == State.FILTER) + if(vertex.getVertexValue().getState() == State.FILTER + || vertex.getVertexValue().getState() == State.FINAL_VERTEX) getRecordWriter().write(vertex.getVertexId(),vertex.getVertexValue()); } }