aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorReynold Xin <rxin@apache.org>2013-12-05 14:55:26 -0800
committerReynold Xin <rxin@apache.org>2013-12-05 14:55:26 -0800
commit3fc4534d19a7abf7dcb6c9ebe17e5e29f1febbc5 (patch)
tree56b27d66555db982ff294194a7f48aac408ecf4f /core
parente0347ba6c74fba51d2ac5c0a8becb3dd6d5c4fd0 (diff)
downloadspark-3fc4534d19a7abf7dcb6c9ebe17e5e29f1febbc5.tar.gz
spark-3fc4534d19a7abf7dcb6c9ebe17e5e29f1febbc5.tar.bz2
spark-3fc4534d19a7abf7dcb6c9ebe17e5e29f1febbc5.zip
wip delta join.
Diffstat (limited to 'core')
-rw-r--r--core/src/main/scala/org/apache/spark/util/collection/BitSet.scala4
1 files changed, 4 insertions, 0 deletions
diff --git a/core/src/main/scala/org/apache/spark/util/collection/BitSet.scala b/core/src/main/scala/org/apache/spark/util/collection/BitSet.scala
index 1f794379f7..0e12779152 100644
--- a/core/src/main/scala/org/apache/spark/util/collection/BitSet.scala
+++ b/core/src/main/scala/org/apache/spark/util/collection/BitSet.scala
@@ -102,6 +102,10 @@ class BitSet(numBits: Int) {
words(index >> 6) |= bitmask // div by 64 and mask
}
+ def unset(index: Int) {
+ val bitmask = 1L << (index & 0x3f) // mod 64 and shift
+ words(index >> 6) &= ~bitmask // div by 64 and mask
+ }
/**
* Return the value of the bit with the specified index. The value is true if the bit with