Repository: samza Updated Branches: refs/heads/0.14.1 06039b789 -> 4b19efefe
SAMZA-1704: Fix compatibility issues with scala 2.12 Need to add override keyword for overriding a method in scala 2.12. Author: xiliu <[email protected]> Reviewers: Prateek M <[email protected]> Closes #508 from xinyuiscool/SAMZA-1704 (cherry picked from commit 31a9e4aea8a8233853334b7ed70da8694f42bd52) Signed-off-by: xiliu <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/4b19efef Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/4b19efef Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/4b19efef Branch: refs/heads/0.14.1 Commit: 4b19efefec78ec6d2f7352dfa1972a9d04181861 Parents: 06039b7 Author: xiliu <[email protected]> Authored: Mon May 7 18:14:29 2018 -0700 Committer: xiliu <[email protected]> Committed: Mon May 7 18:15:01 2018 -0700 ---------------------------------------------------------------------- .../scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala | 2 +- .../main/scala/org/apache/samza/storage/kv/AccessLoggedStore.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/4b19efef/samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala ---------------------------------------------------------------------- diff --git a/samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala b/samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala index 06fb584..e0ee576 100644 --- a/samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala +++ b/samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala @@ -204,7 +204,7 @@ class RocksDbKeyValueStore( new RocksDbIterator(iter) } - def iterate(from: Array[Byte], to: Array[Byte]): KeyValueIterable[Array[Byte], Array[Byte]] = { + override def iterate(from: Array[Byte], to: Array[Byte]): KeyValueIterable[Array[Byte], Array[Byte]] = { //snapshot the iterator val snapshotIter : RocksDbRangeIterator = range(from, to).asInstanceOf[RocksDbRangeIterator] new KeyValueIterable[Array[Byte], Array[Byte]] { http://git-wip-us.apache.org/repos/asf/samza/blob/4b19efef/samza-kv/src/main/scala/org/apache/samza/storage/kv/AccessLoggedStore.scala ---------------------------------------------------------------------- diff --git a/samza-kv/src/main/scala/org/apache/samza/storage/kv/AccessLoggedStore.scala b/samza-kv/src/main/scala/org/apache/samza/storage/kv/AccessLoggedStore.scala index 67fd011..f6fca15 100644 --- a/samza-kv/src/main/scala/org/apache/samza/storage/kv/AccessLoggedStore.scala +++ b/samza-kv/src/main/scala/org/apache/samza/storage/kv/AccessLoggedStore.scala @@ -92,7 +92,7 @@ class AccessLoggedStore[K, V]( store.all() } - def iterate(from: K, to: K): KeyValueIterable[K, V] = { + override def iterate(from: K, to: K): KeyValueIterable[K, V] = { val list : util.ArrayList[K] = new util.ArrayList[K]() list.add(from) list.add(to)
