You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2016/01/25 00:29:17 UTC
[09/50] storm git commit: Merge branch 'STORM-1450' of
https://github.com/jerrypeng/storm [STORM-1450] - Fix minor bugs and refactor
code in ResourceAwareScheduler
Merge branch 'STORM-1450' of https://github.com/jerrypeng/storm
[STORM-1450] - Fix minor bugs and refactor code in ResourceAwareScheduler
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/6e151625
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/6e151625
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/6e151625
Branch: refs/heads/1.x-branch
Commit: 6e15162561805d678c30fd7dc0d80f9545669b33
Parents: c9d687e 0529410
Author: Boyang Jerry Peng <je...@yahoo-inc.com>
Authored: Tue Jan 19 10:00:27 2016 -0600
Committer: Boyang Jerry Peng <je...@yahoo-inc.com>
Committed: Tue Jan 19 10:00:27 2016 -0600
----------------------------------------------------------------------
.../src/clj/org/apache/storm/daemon/nimbus.clj | 11 +-
.../jvm/org/apache/storm/scheduler/Cluster.java | 54 ++-
.../storm/scheduler/SchedulerAssignment.java | 3 +
.../scheduler/SchedulerAssignmentImpl.java | 14 +
.../apache/storm/scheduler/TopologyDetails.java | 2 +-
.../org/apache/storm/scheduler/WorkerSlot.java | 24 +-
.../scheduler/resource/ClusterStateData.java | 101 ++++++
.../storm/scheduler/resource/RAS_Node.java | 342 +++++++++----------
.../storm/scheduler/resource/RAS_Nodes.java | 122 +++----
.../resource/ResourceAwareScheduler.java | 44 ++-
.../DefaultResourceAwareStrategy.java | 135 ++++----
.../strategies/scheduling/IStrategy.java | 11 +-
.../scheduler/resource_aware_scheduler_test.clj | 8 +-
.../resource/TestResourceAwareScheduler.java | 161 +++++++++
14 files changed, 658 insertions(+), 374 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/6e151625/storm-core/src/clj/org/apache/storm/daemon/nimbus.clj
----------------------------------------------------------------------