storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [15/16] storm git commit: Merge branch 'STORM-634' of https://github.com/Parth-Brahmbhatt/incubator-storm into STORM-634
Date Wed, 18 Mar 2015 19:39:22 GMT
Merge branch 'STORM-634' of https://github.com/Parth-Brahmbhatt/incubator-storm into STORM-634

STORM-634: Storm serialization changed to thrift to support rolling upgrade.


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/66274f34
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/66274f34
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/66274f34

Branch: refs/heads/master
Commit: 66274f342c8d35e4e952f2d22a6250a1a6760287
Parents: 1ea378d 93b1b65
Author: Robert (Bobby) Evans <evans@yahoo-inc.com>
Authored: Wed Mar 18 14:20:15 2015 -0500
Committer: Robert (Bobby) Evans <evans@yahoo-inc.com>
Committed: Wed Mar 18 14:20:15 2015 -0500

----------------------------------------------------------------------
 conf/defaults.yaml                              |    2 +-
 storm-core/src/clj/backtype/storm/cluster.clj   |   58 +-
 storm-core/src/clj/backtype/storm/config.clj    |    7 +-
 storm-core/src/clj/backtype/storm/converter.clj |  201 +++
 .../src/clj/backtype/storm/daemon/common.clj    |   10 +-
 .../src/clj/backtype/storm/daemon/executor.clj  |    4 +-
 .../src/clj/backtype/storm/daemon/nimbus.clj    |  106 +-
 .../src/clj/backtype/storm/daemon/worker.clj    |    3 +-
 storm-core/src/clj/backtype/storm/stats.clj     |   78 +-
 storm-core/src/clj/backtype/storm/thrift.clj    |   17 +-
 .../storm/coordination/BatchBoltExecutor.java   |    4 +-
 .../backtype/storm/generated/Assignment.java    |  983 ++++++++++++++
 .../storm/generated/ClusterWorkerHeartbeat.java |  673 ++++++++++
 .../backtype/storm/generated/ExecutorStats.java |  105 +-
 .../jvm/backtype/storm/generated/NodeInfo.java  |  556 ++++++++
 .../jvm/backtype/storm/generated/StormBase.java | 1211 ++++++++++++++++++
 .../storm/generated/SupervisorInfo.java         | 1182 +++++++++++++++++
 .../storm/generated/TopologyActionOptions.java  |  387 ++++++
 .../storm/generated/TopologyStatus.java         |   68 +
 .../DefaultSerializationDelegate.java           |   11 +-
 .../GzipBridgeSerializationDelegate.java        |    7 +-
 .../GzipSerializationDelegate.java              |   10 +-
 .../serialization/SerializationDelegate.java    |    2 +-
 .../ThriftSerializationDelegate.java            |   52 +
 .../storm/topology/TopologyBuilder.java         |    6 +-
 .../jvm/backtype/storm/utils/LocalState.java    |    4 +-
 .../src/jvm/backtype/storm/utils/Utils.java     |   82 +-
 storm-core/src/jvm/storm/trident/Stream.java    |    2 +-
 .../src/jvm/storm/trident/TridentTopology.java  |    6 +-
 storm-core/src/py/storm/ttypes.py               |  827 +++++++++++-
 storm-core/src/storm.thrift                     |   51 +
 .../test/clj/backtype/storm/cluster_test.clj    |   25 +-
 .../test/clj/backtype/storm/nimbus_test.clj     |    6 +-
 .../GzipBridgeSerializationDelegateTest.java    |    6 +-
 .../ThriftBridgeSerializationDelegateTest.java  |   60 +
 35 files changed, 6606 insertions(+), 206 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/66274f34/conf/defaults.yaml
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/storm/blob/66274f34/storm-core/src/clj/backtype/storm/daemon/nimbus.clj
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/storm/blob/66274f34/storm-core/src/clj/backtype/storm/thrift.clj
----------------------------------------------------------------------


Mime
View raw message