Repository: incubator-samza Updated Branches: refs/heads/0.7.1 cb00d7dee -> ca391273d
SAMZA-321; make next fail when going beyond range kv store Project: http://git-wip-us.apache.org/repos/asf/incubator-samza/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-samza/commit/ca391273 Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/ca391273 Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/ca391273 Branch: refs/heads/0.7.1 Commit: ca391273d5402a1f98e0a5205b3f393068cd5fe9 Parents: cb00d7d Author: Chinmay Soman <[email protected]> Authored: Wed Jul 9 13:43:15 2014 -0700 Committer: Chris Riccomini <[email protected]> Committed: Wed Jul 9 13:47:25 2014 -0700 ---------------------------------------------------------------------- .../scala/org/apache/samza/storage/kv/LevelDbKeyValueStore.scala | 4 ++++ .../scala/org/apache/samza/storage/kv/TestKeyValueStores.scala | 1 + 2 files changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/ca391273/samza-kv/src/main/scala/org/apache/samza/storage/kv/LevelDbKeyValueStore.scala ---------------------------------------------------------------------- diff --git a/samza-kv/src/main/scala/org/apache/samza/storage/kv/LevelDbKeyValueStore.scala b/samza-kv/src/main/scala/org/apache/samza/storage/kv/LevelDbKeyValueStore.scala index dae3c2c..72562cf 100644 --- a/samza-kv/src/main/scala/org/apache/samza/storage/kv/LevelDbKeyValueStore.scala +++ b/samza-kv/src/main/scala/org/apache/samza/storage/kv/LevelDbKeyValueStore.scala @@ -182,6 +182,10 @@ class LevelDbKeyValueStore( def remove() = iter.remove() def hasNext() = iter.hasNext() def next() = { + if (!hasNext()) { + throw new NoSuchElementException + } + val curr = iter.next val key = curr.getKey val value = curr.getValue http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/ca391273/samza-kv/src/test/scala/org/apache/samza/storage/kv/TestKeyValueStores.scala ---------------------------------------------------------------------- diff --git a/samza-kv/src/test/scala/org/apache/samza/storage/kv/TestKeyValueStores.scala b/samza-kv/src/test/scala/org/apache/samza/storage/kv/TestKeyValueStores.scala index bed9f84..d438a8f 100644 --- a/samza-kv/src/test/scala/org/apache/samza/storage/kv/TestKeyValueStores.scala +++ b/samza-kv/src/test/scala/org/apache/samza/storage/kv/TestKeyValueStores.scala @@ -294,6 +294,7 @@ class TestKeyValueStores(typeOfStore: String) { assertEquals(v, s(entry.getValue)) } assertFalse(iter.hasNext) + intercept[NoSuchElementException] { iter.next() } } /**
