Merge branch 'restart_optimizations' of github.com:tushargosavi/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/88bf3362 Tree: http://git-wip-us.apache.org/repos/asf/apex-core/tree/88bf3362 Diff: http://git-wip-us.apache.org/repos/asf/apex-core/diff/88bf3362 Branch: refs/heads/master Commit: 88bf336271d5c9c375ea9054b4c4f17b0e277102 Parents: 412a3bd 8825f5f Author: Pramod Immaneni <[email protected]> Authored: Mon Apr 10 14:11:22 2017 -0700 Committer: Pramod Immaneni <[email protected]> Committed: Mon Apr 10 14:11:22 2017 -0700 ---------------------------------------------------------------------- .../common/util/AsyncFSStorageAgent.java | 14 +- .../datatorrent/common/util/FSStorageAgent.java | 11 + .../apex/common/util/AsyncStorageAgent.java | 54 +++++ .../apex/common/util/CascadeStorageAgent.java | 202 +++++++++++++++++++ .../common/util/CascadeStorageAgentTest.java | 116 +++++++++++ .../java/com/datatorrent/stram/StramClient.java | 12 +- .../stram/StreamingContainerManager.java | 49 +++-- .../java/com/datatorrent/stram/engine/Node.java | 17 +- .../stram/plan/physical/PhysicalPlan.java | 9 +- .../datatorrent/stram/StramRecoveryTest.java | 45 ++++- 10 files changed, 493 insertions(+), 36 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-core/blob/88bf3362/engine/src/main/java/com/datatorrent/stram/plan/physical/PhysicalPlan.java ----------------------------------------------------------------------
