You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ja...@apache.org on 2018/10/12 02:48:03 UTC
[19/32] 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/531b668e
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/531b668e
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/531b668e
Branch: refs/heads/master
Commit: 531b668ea52a701559dbc2b3515031d02cc22407
Parents: 44329cf 3c78e06
Author: Jagadish <jv...@linkedin.com>
Authored: Thu Oct 11 12:32:27 2018 -0700
Committer: Jagadish <jv...@linkedin.com>
Committed: Thu Oct 11 12:32:27 2018 -0700
----------------------------------------------------------------------
.../documentation/versioned/azure/eventhubs.md | 30 +--
.../versioned/connectors/eventhubs.md | 22 +-
.../versioned/jobs/configuration-table.html | 32 +--
.../versioned/jobs/samza-configurations.md | 32 +--
.../descriptors/GenericSystemDescriptor.java | 6 -
.../org/apache/samza/storage/StorageEngine.java | 4 +-
.../samza/system/eventhub/EventHubConfig.java | 45 ++--
.../eventhub/EventHubsInputDescriptor.java | 121 +++++++++++
.../eventhub/EventHubsOutputDescriptor.java | 104 +++++++++
.../eventhub/EventHubsSystemDescriptor.java | 217 +++++++++++++++++++
.../eventhub/producer/AsyncSystemProducer.java | 3 +-
.../eventhub/TestEventHubsInputDescriptor.java | 91 ++++++++
.../eventhub/TestEventHubsOutputDescriptor.java | 88 ++++++++
.../eventhub/TestEventHubsSystemDescriptor.java | 112 ++++++++++
.../org/apache/samza/execution/JobPlanner.java | 7 +-
.../descriptors/DelegatingSystemDescriptor.java | 6 -
.../samza/storage/TaskStorageManager.scala | 2 +-
.../system/kafka/KafkaSystemDescriptor.java | 6 -
.../samza/storage/kv/RocksDbKeyValueStore.scala | 2 +-
.../samza/storage/kv/AccessLoggedStore.scala | 6 +-
.../kv/BaseKeyValueStorageEngineFactory.scala | 2 +-
.../storage/kv/KeyValueStorageEngine.scala | 10 +-
.../storage/kv/TestKeyValueStorageEngine.scala | 6 +-
23 files changed, 842 insertions(+), 112 deletions(-)
----------------------------------------------------------------------