apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pra...@apache.org
Subject [2/2] apex-core git commit: Merge branch 'restart_optimizations' of github.com:tushargosavi/apex-core
Date Mon, 10 Apr 2017 22:27:01 GMT
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 <pramod@datatorrent.com>
Authored: Mon Apr 10 14:11:22 2017 -0700
Committer: Pramod Immaneni <pramod@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
----------------------------------------------------------------------


Mime
View raw message