Merge branch 'APEXCORE-504' of github.com:vrozov/apex-core
Project: http://git-wip-us.apache.org/repos/asf/apex-core/repo Commit: http://git-wip-us.apache.org/repos/asf/apex-core/commit/d90e8829 Tree: http://git-wip-us.apache.org/repos/asf/apex-core/tree/d90e8829 Diff: http://git-wip-us.apache.org/repos/asf/apex-core/diff/d90e8829 Branch: refs/heads/master Commit: d90e8829fd89edba66ee5b79296a69fd9a5b6dd8 Parents: 491e2e3 283ebe2 Author: Pramod Immaneni <[email protected]> Authored: Mon Mar 20 23:25:06 2017 -0700 Committer: Pramod Immaneni <[email protected]> Committed: Mon Mar 20 23:25:06 2017 -0700 ---------------------------------------------------------------------- .../stram/StreamingContainerAgent.java | 53 +++++++++----------- .../stram/StreamingContainerManager.java | 4 +- .../stram/plan/logical/LogicalPlan.java | 39 +++++++++----- .../stram/plan/physical/PhysicalPlan.java | 16 +++--- .../stram/plan/physical/StreamMapping.java | 13 ++--- .../com/datatorrent/stram/StreamCodecTest.java | 8 +-- .../stram/plan/StreamPersistanceTests.java | 2 +- 7 files changed, 69 insertions(+), 66 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-core/blob/d90e8829/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-core/blob/d90e8829/engine/src/main/java/com/datatorrent/stram/plan/logical/LogicalPlan.java ----------------------------------------------------------------------
