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:03 UTC
[06/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/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 <bs...@linkedin.com>
Authored: Wed Oct 25 09:50:37 2017 -0700
Committer: Boris Shkolnik <bs...@linkedin.com>
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(-)
----------------------------------------------------------------------