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 <jvenkatra...@linkedin.com> Authored: Thu Oct 11 12:32:27 2018 -0700 Committer: Jagadish <jvenkatra...@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(-) ----------------------------------------------------------------------