Merge branch 'master' of https://github.com/apache/samza
Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/d4620d66 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/d4620d66 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/d4620d66 Branch: refs/heads/NewKafkaSystemConsumer Commit: d4620d6690f74cad9472d0e27a1b31aeb4156c54 Parents: 410ce78 958edc4 Author: Boris S <[email protected]> Authored: Tue Oct 24 17:11:48 2017 -0700 Committer: Boris S <[email protected]> Committed: Tue Oct 24 17:11:48 2017 -0700 ---------------------------------------------------------------------- .../apache/samza/storage/kv/KeyValueStore.java | 69 ++++--------- .../kafka/KafkaCheckpointManager.scala | 103 +++++++------------ .../kv/inmemory/InMemoryKeyValueStore.scala | 8 -- .../samza/storage/kv/RocksDbKeyValueStore.scala | 86 ++++++---------- .../storage/kv/TestRocksDbKeyValueStore.scala | 4 +- .../apache/samza/storage/kv/CachedStore.scala | 2 +- .../samza/storage/kv/MockKeyValueStore.scala | 8 -- 7 files changed, 93 insertions(+), 187 deletions(-) ----------------------------------------------------------------------
