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/21 23:04:47 UTC

[2/2] apex-core git commit: Merge branch 'APEXCORE-649' of github.com:tushargosavi/apex-core

Merge branch 'APEXCORE-649' 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/cfe9cefe
Tree: http://git-wip-us.apache.org/repos/asf/apex-core/tree/cfe9cefe
Diff: http://git-wip-us.apache.org/repos/asf/apex-core/diff/cfe9cefe

Branch: refs/heads/master
Commit: cfe9cefed1400f83dc95a17a1f1f8de921d552b1
Parents: 6cb3e35 d705ed4
Author: Pramod Immaneni <pr...@datatorrent.com>
Authored: Fri Apr 21 14:51:47 2017 -0700
Committer: Pramod Immaneni <pr...@datatorrent.com>
Committed: Fri Apr 21 14:51:47 2017 -0700

----------------------------------------------------------------------
 .../stram/StreamingAppMasterService.java        |   2 +
 .../stram/StreamingContainerManager.java        |   2 +
 .../plugin/AbstractApexPluginDispatcher.java    | 216 +++++++++++++++++++
 .../AbstractDAGExecutionPluginContext.java      |   9 +-
 .../engine/plugin/ApexPluginDispatcher.java     |   8 +
 .../apex/engine/plugin/ApexPluginManager.java   | 191 ----------------
 .../plugin/DefaultApexPluginDispatcher.java     |   4 +-
 .../apache/apex/engine/plugin/DebugPlugin.java  |  29 +--
 .../apache/apex/engine/plugin/PluginTests.java  |  25 +--
 9 files changed, 242 insertions(+), 244 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/apex-core/blob/cfe9cefe/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java
----------------------------------------------------------------------