commit | 71d3e481acfe0be35525bba0de4388a8145fca53 | [log] [tgz] |
---|---|---|
author | buyingyi <buyingyi@gmail.com> | Fri Oct 18 00:34:16 2013 -0700 |
committer | buyingyi <buyingyi@gmail.com> | Fri Oct 18 00:34:16 2013 -0700 |
tree | 68d97d67c8645cd3b91ca2ebb1405ca5a988d49e | |
parent | a5702c87228ddbeb178ce5da2d3bec63ba9339e5 [diff] |
use in-place update for smaller sized updates
diff --git a/pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/util/CopyUpdateUtil.java b/pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/util/CopyUpdateUtil.java index 58ec8ab..c71da7a 100644 --- a/pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/util/CopyUpdateUtil.java +++ b/pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/util/CopyUpdateUtil.java
@@ -37,7 +37,7 @@ int srcStart = fieldEndOffsets[0]; int srcLen = fieldEndOffsets[1] - fieldEndOffsets[0]; // the updated vertex size int frSize = frameTuple.getFieldLength(1); // the vertex binary size in the leaf page - if (srcLen == frSize) { + if (srcLen <= frSize) { System.arraycopy(cloneUpdateTb.getByteArray(), srcStart, frameTuple.getFieldData(1), frameTuple.getFieldStart(1), srcLen); cloneUpdateTb.reset();