Minor fixes to KeyValueStore and RocksDBKeyValueStore master
authorPrateek Maheshwari <pmaheshw@linkedin.com>
Thu, 19 Oct 2017 18:36:02 +0000 (11:36 -0700)
committerPrateek Maheshwari <pmaheshw@linkedin.com>
Thu, 19 Oct 2017 18:36:02 +0000 (11:36 -0700)
commit958edc42f59a1891e14276251462236abd2af5b9
treebf999ae762ca80a956c140f380e6345ea479ec2d
parent62904334b6269f9862b4139987b45bdb3f8b35dd
Minor fixes to KeyValueStore and RocksDBKeyValueStore

1. Replaced extension class in KeyValueStore with default methods.
2. Fixed formatting in RocksDBKeyValueStore#openDB.
3. Now logs original RocksDBException on errors opening the db. Other minor log message cleanup.

Author: Prateek Maheshwari <pmaheshw@linkedin.com>

Reviewers: Jacob Maes <jmakes@apache.org>

Closes #332 from prateekm/store-fixes
samza-api/src/main/java/org/apache/samza/storage/kv/KeyValueStore.java
samza-kv-inmemory/src/main/scala/org/apache/samza/storage/kv/inmemory/InMemoryKeyValueStore.scala
samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala
samza-kv/src/main/scala/org/apache/samza/storage/kv/CachedStore.scala
samza-kv/src/test/scala/org/apache/samza/storage/kv/MockKeyValueStore.scala