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) <nickpa...@gmail.com> Authored: Mon Feb 27 12:59:49 2017 -0800 Committer: Yi Pan (Data Infrastructure) <nickpa...@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(-) ----------------------------------------------------------------------