commit 412bfa5934583adc495698ecfaa50c5630dd67b9
author buyingyi <buyingyi@gmail.com> Sun Jul 28 03:05:29 2013 -0700
committer buyingyi <buyingyi@gmail.com> Sun Jul 28 03:05:29 2013 -0700
tree 2bb42d81d9befa7c9544c53f4038bfa632d7708c
parent dbedd59e17cd7910fa4f174d38b03379aef7289d

use upsert instead of update

pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/util/UpdateBuffer.java

diff --git a/pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/util/UpdateBuffer.java b/pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/util/UpdateBuffer.java
index ea1e02e..49c5bb8 100644
--- a/pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/util/UpdateBuffer.java
+++ b/pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/util/UpdateBuffer.java
@@ -96,7 +96,7 @@
             fta.reset(buffer);
             for (int j = 0; j < fta.getTupleCount(); j++) {
                 tuple.reset(fta, j);
-                bta.update(tuple);
+                bta.upsert(tuple);
             }
         }