You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2015/11/24 18:57:22 UTC
[15/16] storm git commit: Merge branch 'worker-hooks' of
https://github.com/socialrank/storm into STORM-126
Merge branch 'worker-hooks' of https://github.com/socialrank/storm into STORM-126
STORM-126: Add Lifecycle support API for worker nodes
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/8bcb2f29
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/8bcb2f29
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/8bcb2f29
Branch: refs/heads/master
Commit: 8bcb2f29d0fa043631d75f8e7a1a13adf8f5e2bd
Parents: ccf3fd2 9bc9350
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Tue Nov 24 09:15:01 2015 -0600
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Tue Nov 24 09:15:01 2015 -0600
----------------------------------------------------------------------
.../src/clj/backtype/storm/daemon/common.clj | 30 +-
.../src/clj/backtype/storm/daemon/worker.clj | 27 +-
.../backtype/storm/generated/Assignment.java | 244 ++--
.../jvm/backtype/storm/generated/BoltStats.java | 340 ++---
.../storm/generated/ClusterSummary.java | 108 +-
.../storm/generated/ClusterWorkerHeartbeat.java | 52 +-
.../storm/generated/ComponentPageInfo.java | 220 ++--
.../backtype/storm/generated/Credentials.java | 44 +-
.../backtype/storm/generated/ExecutorStats.java | 160 +--
.../storm/generated/LSApprovedWorkers.java | 44 +-
.../generated/LSSupervisorAssignments.java | 48 +-
.../backtype/storm/generated/LSTopoHistory.java | 64 +-
.../storm/generated/LSTopoHistoryList.java | 36 +-
.../storm/generated/LSWorkerHeartbeat.java | 36 +-
.../storm/generated/LocalAssignment.java | 36 +-
.../storm/generated/LocalStateData.java | 48 +-
.../jvm/backtype/storm/generated/LogConfig.java | 48 +-
.../jvm/backtype/storm/generated/Nimbus.java | 36 +-
.../jvm/backtype/storm/generated/NodeInfo.java | 32 +-
.../storm/generated/RebalanceOptions.java | 44 +-
.../backtype/storm/generated/SpoutStats.java | 224 ++--
.../jvm/backtype/storm/generated/StormBase.java | 92 +-
.../backtype/storm/generated/StormTopology.java | 251 +++-
.../storm/generated/SupervisorInfo.java | 152 +--
.../storm/generated/SupervisorSummary.java | 44 +-
.../storm/generated/TopologyHistoryInfo.java | 32 +-
.../backtype/storm/generated/TopologyInfo.java | 164 +--
.../storm/generated/TopologyPageInfo.java | 96 +-
.../backtype/storm/generated/TopologyStats.java | 220 ++--
.../backtype/storm/hooks/BaseWorkerHook.java | 51 +
.../jvm/backtype/storm/hooks/IWorkerHook.java | 44 +
.../storm/topology/TopologyBuilder.java | 47 +-
.../storm/utils/ThriftTopologyUtils.java | 36 +-
storm-core/src/py/storm/Nimbus.py | 14 +-
storm-core/src/py/storm/ttypes.py | 1239 +++++++++---------
storm-core/src/storm.thrift | 11 +-
.../storm/topology/TopologyBuilderTest.java | 5 +
.../storm/utils/ThriftTopologyUtilsTest.java | 94 ++
38 files changed, 2466 insertions(+), 2047 deletions(-)
----------------------------------------------------------------------