You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by bo...@apache.org on 2018/09/18 23:01:00 UTC
[03/47] samza git commit: Merge branch 'master' of
https://github.com/apache/samza
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 <bo...@apache.org>
Authored: Tue Oct 24 17:11:48 2017 -0700
Committer: Boris S <bo...@apache.org>
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(-)
----------------------------------------------------------------------