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 <[email protected]> Authored: Thu Mar 10 20:58:34 2016 -0800 Committer: Vlad Rozov <[email protected]> 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 ----------------------------------------------------------------------
