commit | 7059586dccba897ad1fb18c9b6b909ed081e3b10 | [log] [tgz] |
---|---|---|
author | buyingyi <buyingyi@gmail.com> | Wed Jul 03 21:31:35 2013 -0700 |
committer | buyingyi <buyingyi@gmail.com> | Wed Jul 03 21:31:35 2013 -0700 |
tree | bce733bc72eb2214fc39a51b98716769f29ba2c4 | |
parent | 12091ef7148df1a418ca3e2e30e82879e6c84de4 [diff] |
fix inl right outer join
diff --git a/pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/std/IndexNestedLoopRightOuterJoinOperatorNodePushable.java b/pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/std/IndexNestedLoopRightOuterJoinOperatorNodePushable.java index 204d8ce..dd6ee3c 100644 --- a/pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/std/IndexNestedLoopRightOuterJoinOperatorNodePushable.java +++ b/pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/std/IndexNestedLoopRightOuterJoinOperatorNodePushable.java
@@ -98,7 +98,6 @@ try { treeIndexOpHelper.open(); index = (ITreeIndex) treeIndexOpHelper.getIndexInstance(); - setCursor(); writer.open(); // construct range predicate @@ -132,6 +131,7 @@ appender.reset(writeBuffer, true); indexAccessor = index.createAccessor(NoOpOperationCallback.INSTANCE, NoOpOperationCallback.INSTANCE); + setCursor(); /** set the search cursor */ rangePred.setLowKey(null, true);