You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ni...@apache.org on 2017/02/27 21:01:40 UTC
[2/3] samza git commit: Merge branch 'SAMZA-1093' into
samza-fluent-api-v1
Merge branch 'SAMZA-1093' into samza-fluent-api-v1
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/cf267f8a
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/cf267f8a
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/cf267f8a
Branch: refs/heads/samza-fluent-api-v1
Commit: cf267f8a5e21aff4b37feb30557231515753b840
Parents: d39bce9 82b839f
Author: Yi Pan (Data Infrastructure) <ni...@gmail.com>
Authored: Mon Feb 27 12:59:49 2017 -0800
Committer: Yi Pan (Data Infrastructure) <ni...@gmail.com>
Committed: Mon Feb 27 12:59:49 2017 -0800
----------------------------------------------------------------------
.../samza/operators/StreamGraphBuilder.java | 2 +
.../apache/samza/container/RunLoopFactory.java | 16 +-
.../org/apache/samza/task/TaskFactories.java | 95 +++++++
.../org/apache/samza/util/ScalaToJavaUtils.java | 41 +++
.../apache/samza/container/SamzaContainer.scala | 81 +++---
.../apache/samza/task/TestTaskFactories.java | 256 +++++++++++++++++++
.../testUtils/InvalidStreamGraphBuilder.java | 25 ++
.../samza/testUtils/TestAsyncStreamTask.java | 35 +++
.../samza/testUtils/TestStreamGraphBuilder.java | 33 +++
.../apache/samza/testUtils/TestStreamTask.java | 34 +++
.../apache/samza/zk/TestZkLeaderElector.java | 2 +-
.../java/org/apache/samza/zk/TestZkUtils.java | 2 +-
.../test/integration/StreamTaskTestUtil.scala | 3 +-
13 files changed, 564 insertions(+), 61 deletions(-)
----------------------------------------------------------------------