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/11/27 09:48:48 UTC
[41/50] 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/429277b7
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/429277b7
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/429277b7
Branch: refs/heads/master
Commit: 429277b706a7f7fd3c531e38777099aee9c4530c
Parents: 841b8fa 8723c3f
Author: Jagadish <jv...@linkedin.com>
Authored: Wed Oct 31 14:22:21 2018 -0700
Committer: Jagadish <jv...@linkedin.com>
Committed: Wed Oct 31 14:22:21 2018 -0700
----------------------------------------------------------------------
RELEASE.md | 47 ++++++--------
checkstyle/checkstyle-suppressions.xml | 13 ++--
checkstyle/checkstyle.xml | 9 ++-
.../samza/application/SamzaApplication.java | 25 ++++----
.../samza/application/StreamApplication.java | 52 ++++++++-------
.../samza/application/TaskApplication.java | 27 ++++----
.../descriptors/ApplicationDescriptor.java | 63 +++++++++++--------
.../StreamApplicationDescriptor.java | 13 ++--
.../descriptors/TaskApplicationDescriptor.java | 22 ++++---
.../context/ApplicationContainerContext.java | 28 +++++----
.../ApplicationContainerContextFactory.java | 12 ++--
.../samza/context/ApplicationTaskContext.java | 19 +++---
.../context/ApplicationTaskContextFactory.java | 12 ++--
.../apache/samza/context/ContainerContext.java | 4 +-
.../java/org/apache/samza/context/Context.java | 10 +--
.../org/apache/samza/context/TaskContext.java | 11 ++--
.../samza/system/ExtendedSystemAdmin.java | 37 -----------
.../org/apache/samza/system/SystemAdmin.java | 12 ++++
.../system/descriptors/StreamExpander.java | 7 ++-
.../TransformingInputDescriptorProvider.java | 10 +--
.../main/java/org/apache/samza/table/Table.java | 36 ++++++-----
.../table/descriptors/TableDescriptor.java | 28 +++++----
.../apache/samza/system/TestSystemAdmin.java | 2 +-
.../system/inmemory/InMemorySystemProducer.java | 22 +++++--
.../samza/system/StreamMetadataCache.scala | 4 +-
.../apache/samza/system/MockSystemFactory.java | 9 +--
.../system/inmemory/TestInMemorySystem.java | 28 +++++++++
.../samza/checkpoint/TestCheckpointTool.scala | 2 +-
.../samza/system/kafka/KafkaSystemAdmin.java | 39 +-----------
.../kafka_deprecated/KafkaSystemAdmin.scala | 66 +-------------------
.../system/kafka/TestKafkaSystemAdmin.scala | 19 +++---
.../kafka_deprecated/TestKafkaSystemAdmin.scala | 41 ------------
.../descriptors/InMemoryInputDescriptor.java | 2 +-
.../descriptors/InMemoryOutputDescriptor.java | 2 +-
34 files changed, 319 insertions(+), 414 deletions(-)
----------------------------------------------------------------------