commit | 9f5c95694430cc28af84076b5e9d3e444ebb3291 | [log] [tgz] |
---|---|---|
author | buyingyi <buyingyi@gmail.com> | Fri Jul 26 23:54:07 2013 -0700 |
committer | buyingyi <buyingyi@gmail.com> | Fri Jul 26 23:54:07 2013 -0700 |
tree | a4d737370c46ede771ee98869aada136ae8b9c84 | |
parent | ef2a84fc60b2079401aab2a91015c02ec799af18 [diff] |
allow multiple deletions in pregelix
diff --git a/hyracks/hyracks-storage-am-btree/src/main/java/edu/uci/ics/hyracks/storage/am/btree/impls/BTree.java b/hyracks/hyracks-storage-am-btree/src/main/java/edu/uci/ics/hyracks/storage/am/btree/impls/BTree.java index 689843b..42e876c 100644 --- a/hyracks/hyracks-storage-am-btree/src/main/java/edu/uci/ics/hyracks/storage/am/btree/impls/BTree.java +++ b/hyracks/hyracks-storage-am-btree/src/main/java/edu/uci/ics/hyracks/storage/am/btree/impls/BTree.java
@@ -879,8 +879,12 @@ @Override public void delete(ITupleReference tuple) throws HyracksDataException, TreeIndexException { - ctx.setOperation(IndexOperation.DELETE); - btree.delete(tuple, ctx); + try { + ctx.setOperation(IndexOperation.DELETE); + btree.delete(tuple, ctx); + } catch (BTreeNonExistentKeyException e) { + //allow deletion of non-existing keys + } } @Override