You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by vr...@apache.org on 2016/03/11 06:03:25 UTC
[2/2] incubator-apex-core git commit: Merge branch 'APEXCORE-201-PR'
of https://github.com/davidyan74/incubator-apex-core
Merge branch 'APEXCORE-201-PR' of https://github.com/davidyan74/incubator-apex-core
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/7c84e05e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/7c84e05e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/7c84e05e
Branch: refs/heads/master
Commit: 7c84e05e15f759d632597fc577431d4dc083e8b2
Parents: a93fbf3 6e6d6b1
Author: Vlad Rozov <v....@datatorrent.com>
Authored: Thu Mar 10 20:58:34 2016 -0800
Committer: Vlad Rozov <v....@datatorrent.com>
Committed: Thu Mar 10 20:58:34 2016 -0800
----------------------------------------------------------------------
.../stram/StreamingContainerManager.java | 217 +++++++++----------
.../datatorrent/stram/engine/GenericNode.java | 5 +-
.../com/datatorrent/stram/engine/InputNode.java | 4 +-
.../stram/plan/logical/LogicalPlan.java | 16 +-
.../stram/plan/physical/PhysicalPlan.java | 9 +
.../stram/StreamingContainerManagerTest.java | 84 +++++++
6 files changed, 214 insertions(+), 121 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/7c84e05e/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/7c84e05e/engine/src/main/java/com/datatorrent/stram/engine/GenericNode.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/7c84e05e/engine/src/main/java/com/datatorrent/stram/engine/InputNode.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/7c84e05e/engine/src/test/java/com/datatorrent/stram/StreamingContainerManagerTest.java
----------------------------------------------------------------------