You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by pr...@apache.org on 2017/04/10 22:27:01 UTC
[2/2] apex-core git commit: Merge branch 'restart_optimizations' of
github.com:tushargosavi/apex-core
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 <pr...@datatorrent.com>
Authored: Mon Apr 10 14:11:22 2017 -0700
Committer: Pramod Immaneni <pr...@datatorrent.com>
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
----------------------------------------------------------------------