You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by da...@apache.org on 2015/12/21 15:46:49 UTC
[21/23] storm git commit: Merge branch 'STORM-898' of
https://github.com/jerrypeng/storm into STORM-898-merge
Merge branch 'STORM-898' of https://github.com/jerrypeng/storm into STORM-898-merge
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/d790eb5a
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/d790eb5a
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/d790eb5a
Branch: refs/heads/master
Commit: d790eb5abb1952be57f16f9a49f84eff4b0476b5
Parents: 8f9ed06 dc6d0f7
Author: Derek Dagit <de...@yahoo-inc.com>
Authored: Mon Dec 21 08:28:05 2015 -0600
Committer: Derek Dagit <de...@yahoo-inc.com>
Committed: Mon Dec 21 08:28:05 2015 -0600
----------------------------------------------------------------------
conf/defaults.yaml | 6 +
conf/user-resource-pools-example.yaml | 26 +
.../Resource_Aware_Scheduler_overview.md | 227 ++++
...ware_scheduler_default_eviction_strategy.svg | 3 +
.../starter/ResourceAwareExampleTopology.java | 9 +-
.../src/clj/backtype/storm/daemon/nimbus.clj | 14 +-
storm-core/src/jvm/backtype/storm/Config.java | 59 +-
.../jvm/backtype/storm/scheduler/Cluster.java | 71 +
.../storm/scheduler/SupervisorDetails.java | 8 +-
.../backtype/storm/scheduler/Topologies.java | 14 +
.../storm/scheduler/TopologyDetails.java | 157 ++-
.../storm/scheduler/resource/RAS_Node.java | 253 ++--
.../storm/scheduler/resource/RAS_Nodes.java | 160 +++
.../resource/ResourceAwareScheduler.java | 421 ++++--
.../storm/scheduler/resource/ResourceUtils.java | 51 +
.../scheduler/resource/SchedulingResult.java | 116 ++
.../scheduler/resource/SchedulingStatus.java | 40 +
.../backtype/storm/scheduler/resource/User.java | 346 +++++
.../resource/strategies/IStrategy.java | 37 -
.../strategies/ResourceAwareStrategy.java | 479 -------
.../eviction/DefaultEvictionStrategy.java | 126 ++
.../strategies/eviction/IEvictionStrategy.java | 47 +
.../DefaultSchedulingPriorityStrategy.java | 81 ++
.../priority/ISchedulingPriorityStrategy.java | 41 +
.../DefaultResourceAwareStrategy.java | 488 +++++++
.../strategies/scheduling/IStrategy.java | 50 +
.../storm/validation/ConfigValidation.java | 60 +-
.../validation/ConfigValidationAnnotations.java | 9 +
.../scheduler/resource_aware_scheduler_test.clj | 193 ++-
.../jvm/backtype/storm/TestConfigValidate.java | 84 ++
.../resource/TestResourceAwareScheduler.java | 1227 ++++++++++++++++++
.../storm/scheduler/resource/TestUser.java | 111 ++
.../TestUtilsForResourceAwareScheduler.java | 288 ++++
33 files changed, 4418 insertions(+), 884 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/d790eb5a/conf/defaults.yaml
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/d790eb5a/storm-core/src/clj/backtype/storm/daemon/nimbus.clj
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/d790eb5a/storm-core/src/jvm/backtype/storm/Config.java
----------------------------------------------------------------------