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/5e6f5fb5 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/5e6f5fb5 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/5e6f5fb5 Branch: refs/heads/NewKafkaSystemConsumer Commit: 5e6f5fb5f9a9ee12ce35ee8eb1836a058521df20 Parents: 410ce78 5f81b8d Author: Boris Shkolnik <[email protected]> Authored: Wed Oct 25 09:50:37 2017 -0700 Committer: Boris Shkolnik <[email protected]> Committed: Wed Oct 25 09:50:37 2017 -0700 ---------------------------------------------------------------------- build.gradle | 1 + .../apache/samza/storage/kv/KeyValueStore.java | 69 ++++--------- .../apache/samza/task/StreamOperatorTask.java | 2 +- .../samza/execution/TestExecutionPlanner.java | 8 +- .../samza/system/kafka/KafkaStreamSpec.java | 9 ++ .../kafka/KafkaCheckpointManager.scala | 103 +++++++------------ .../kafka/KafkaCheckpointManagerFactory.scala | 21 +--- .../org/apache/samza/config/KafkaConfig.scala | 37 ++++++- .../samza/system/kafka/KafkaSystemAdmin.scala | 9 +- .../samza/system/kafka/KafkaSystemFactory.scala | 22 +++- .../TestKafkaCheckpointManagerFactory.java | 51 +++++++++ .../kafka/TestKafkaSystemFactoryJava.java | 60 +++++++++++ .../kafka/TestKafkaCheckpointManager.scala | 6 +- .../apache/samza/config/TestKafkaConfig.scala | 13 +++ .../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 -- 19 files changed, 303 insertions(+), 216 deletions(-) ----------------------------------------------------------------------
