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:47:49 UTC
[05/32] samza git commit: Merge branch 'master' of
https://github.com/apache/samza into HEAD
Merge branch 'master' of https://github.com/apache/samza into HEAD
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/187ff892
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/187ff892
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/187ff892
Branch: refs/heads/master
Commit: 187ff8929ca08e50df1b2d76c679a1726b9757bc
Parents: 115041a 4ae30f1
Author: Jagadish <jv...@linkedin.com>
Authored: Tue Oct 2 22:07:06 2018 -0700
Committer: Jagadish <jv...@linkedin.com>
Committed: Tue Oct 2 22:07:06 2018 -0700
----------------------------------------------------------------------
.../context/ApplicationContainerContext.java | 46 ++++++++
.../ApplicationContainerContextFactory.java | 44 ++++++++
.../samza/context/ApplicationTaskContext.java | 47 ++++++++
.../context/ApplicationTaskContextFactory.java | 48 ++++++++
.../apache/samza/context/ContainerContext.java | 46 ++++++++
.../java/org/apache/samza/context/Context.java | 77 +++++++++++++
.../org/apache/samza/context/JobContext.java | 46 ++++++++
.../org/apache/samza/context/TaskContext.java | 88 +++++++++++++++
.../apache/samza/job/model/ContainerModel.java | 90 +++++++++++++++
.../org/apache/samza/job/model/TaskModel.java | 110 +++++++++++++++++++
.../samza/scheduler/CallbackScheduler.java | 43 ++++++++
.../java/org/apache/samza/task/TaskContext.java | 1 +
.../apache/samza/container/TaskContextImpl.java | 4 +
.../samza/context/ContainerContextImpl.java | 43 ++++++++
.../org/apache/samza/context/ContextImpl.java | 74 +++++++++++++
.../apache/samza/context/JobContextImpl.java | 49 +++++++++
.../apache/samza/context/TaskContextImpl.java | 87 +++++++++++++++
.../apache/samza/job/model/ContainerModel.java | 92 ----------------
.../org/apache/samza/job/model/TaskModel.java | 105 ------------------
.../samza/scheduler/CallbackSchedulerImpl.java | 44 ++++++++
.../apache/samza/context/TestContextImpl.java | 98 +++++++++++++++++
.../samza/context/TestTaskContextImpl.java | 98 +++++++++++++++++
.../scheduler/TestCallbackSchedulerImpl.java | 72 ++++++++++++
.../apache/samza/test/framework/TestRunner.java | 64 +++++------
.../AsyncStreamTaskIntegrationTest.java | 2 +-
.../StreamApplicationIntegrationTest.java | 23 ----
.../framework/StreamTaskIntegrationTest.java | 4 +-
.../table/TestLocalTableWithSideInputs.java | 14 +--
28 files changed, 1295 insertions(+), 264 deletions(-)
----------------------------------------------------------------------