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/12 15:31:10 UTC
[1/6] storm git commit: Upgrading to thrift 0.9.3
Repository: storm
Updated Branches:
refs/heads/master 34cda0d5c -> 4eccb151b
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/py/storm/ttypes.py
----------------------------------------------------------------------
diff --git a/storm-core/src/py/storm/ttypes.py b/storm-core/src/py/storm/ttypes.py
index 578facb..23a82e1 100644
--- a/storm-core/src/py/storm/ttypes.py
+++ b/storm-core/src/py/storm/ttypes.py
@@ -17,7 +17,7 @@
# limitations under the License.
#
-# Autogenerated by Thrift Compiler (0.9.2)
+# Autogenerated by Thrift Compiler (0.9.3)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
@@ -183,12 +183,12 @@ class JavaObjectArg:
break
if fid == 1:
if ftype == TType.I32:
- self.int_arg = iprot.readI32();
+ self.int_arg = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.I64:
- self.long_arg = iprot.readI64();
+ self.long_arg = iprot.readI64()
else:
iprot.skip(ftype)
elif fid == 3:
@@ -198,17 +198,17 @@ class JavaObjectArg:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.BOOL:
- self.bool_arg = iprot.readBool();
+ self.bool_arg = iprot.readBool()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.STRING:
- self.binary_arg = iprot.readString();
+ self.binary_arg = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 6:
if ftype == TType.DOUBLE:
- self.double_arg = iprot.readDouble();
+ self.double_arg = iprot.readDouble()
else:
iprot.skip(ftype)
else:
@@ -578,7 +578,7 @@ class Grouping:
iprot.skip(ftype)
elif fid == 7:
if ftype == TType.STRING:
- self.custom_serialized = iprot.readString();
+ self.custom_serialized = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 8:
@@ -700,7 +700,7 @@ class StreamInfo:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.BOOL:
- self.direct = iprot.readBool();
+ self.direct = iprot.readBool()
else:
iprot.skip(ftype)
else:
@@ -861,7 +861,7 @@ class ComponentObject:
break
if fid == 1:
if ftype == TType.STRING:
- self.serialized_java = iprot.readString();
+ self.serialized_java = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 2:
@@ -982,7 +982,7 @@ class ComponentCommon:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.I32:
- self.parallelism_hint = iprot.readI32();
+ self.parallelism_hint = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 4:
@@ -2306,22 +2306,22 @@ class TopologySummary:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.I32:
- self.num_tasks = iprot.readI32();
+ self.num_tasks = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.I32:
- self.num_executors = iprot.readI32();
+ self.num_executors = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.I32:
- self.num_workers = iprot.readI32();
+ self.num_workers = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 6:
if ftype == TType.I32:
- self.uptime_secs = iprot.readI32();
+ self.uptime_secs = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 7:
@@ -2341,37 +2341,37 @@ class TopologySummary:
iprot.skip(ftype)
elif fid == 515:
if ftype == TType.I32:
- self.replication_count = iprot.readI32();
+ self.replication_count = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 521:
if ftype == TType.DOUBLE:
- self.requested_memonheap = iprot.readDouble();
+ self.requested_memonheap = iprot.readDouble()
else:
iprot.skip(ftype)
elif fid == 522:
if ftype == TType.DOUBLE:
- self.requested_memoffheap = iprot.readDouble();
+ self.requested_memoffheap = iprot.readDouble()
else:
iprot.skip(ftype)
elif fid == 523:
if ftype == TType.DOUBLE:
- self.requested_cpu = iprot.readDouble();
+ self.requested_cpu = iprot.readDouble()
else:
iprot.skip(ftype)
elif fid == 524:
if ftype == TType.DOUBLE:
- self.assigned_memonheap = iprot.readDouble();
+ self.assigned_memonheap = iprot.readDouble()
else:
iprot.skip(ftype)
elif fid == 525:
if ftype == TType.DOUBLE:
- self.assigned_memoffheap = iprot.readDouble();
+ self.assigned_memoffheap = iprot.readDouble()
else:
iprot.skip(ftype)
elif fid == 526:
if ftype == TType.DOUBLE:
- self.assigned_cpu = iprot.readDouble();
+ self.assigned_cpu = iprot.readDouble()
else:
iprot.skip(ftype)
else:
@@ -2548,17 +2548,17 @@ class SupervisorSummary:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.I32:
- self.uptime_secs = iprot.readI32();
+ self.uptime_secs = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.I32:
- self.num_workers = iprot.readI32();
+ self.num_workers = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.I32:
- self.num_used_workers = iprot.readI32();
+ self.num_used_workers = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 5:
@@ -2577,7 +2577,7 @@ class SupervisorSummary:
(_ktype67, _vtype68, _size66 ) = iprot.readMapBegin()
for _i70 in xrange(_size66):
_key71 = iprot.readString().decode('utf-8')
- _val72 = iprot.readDouble();
+ _val72 = iprot.readDouble()
self.total_resources[_key71] = _val72
iprot.readMapEnd()
else:
@@ -2705,17 +2705,17 @@ class NimbusSummary:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.I32:
- self.port = iprot.readI32();
+ self.port = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.I32:
- self.uptime_secs = iprot.readI32();
+ self.uptime_secs = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.BOOL:
- self.isLeader = iprot.readBool();
+ self.isLeader = iprot.readBool()
else:
iprot.skip(ftype)
elif fid == 5:
@@ -2835,7 +2835,7 @@ class ClusterSummary:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.I32:
- self.nimbus_uptime_secs = iprot.readI32();
+ self.nimbus_uptime_secs = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 3:
@@ -2966,7 +2966,7 @@ class ErrorInfo:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.I32:
- self.error_time_secs = iprot.readI32();
+ self.error_time_secs = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 3:
@@ -2976,7 +2976,7 @@ class ErrorInfo:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.I32:
- self.port = iprot.readI32();
+ self.port = iprot.readI32()
else:
iprot.skip(ftype)
else:
@@ -3081,7 +3081,7 @@ class BoltStats:
for _i107 in xrange(_size103):
_key108 = GlobalStreamId()
_key108.read(iprot)
- _val109 = iprot.readI64();
+ _val109 = iprot.readI64()
_val102[_key108] = _val109
iprot.readMapEnd()
self.acked[_key101] = _val102
@@ -3099,7 +3099,7 @@ class BoltStats:
for _i121 in xrange(_size117):
_key122 = GlobalStreamId()
_key122.read(iprot)
- _val123 = iprot.readI64();
+ _val123 = iprot.readI64()
_val116[_key122] = _val123
iprot.readMapEnd()
self.failed[_key115] = _val116
@@ -3117,7 +3117,7 @@ class BoltStats:
for _i135 in xrange(_size131):
_key136 = GlobalStreamId()
_key136.read(iprot)
- _val137 = iprot.readDouble();
+ _val137 = iprot.readDouble()
_val130[_key136] = _val137
iprot.readMapEnd()
self.process_ms_avg[_key129] = _val130
@@ -3135,7 +3135,7 @@ class BoltStats:
for _i149 in xrange(_size145):
_key150 = GlobalStreamId()
_key150.read(iprot)
- _val151 = iprot.readI64();
+ _val151 = iprot.readI64()
_val144[_key150] = _val151
iprot.readMapEnd()
self.executed[_key143] = _val144
@@ -3153,7 +3153,7 @@ class BoltStats:
for _i163 in xrange(_size159):
_key164 = GlobalStreamId()
_key164.read(iprot)
- _val165 = iprot.readDouble();
+ _val165 = iprot.readDouble()
_val158[_key164] = _val165
iprot.readMapEnd()
self.execute_ms_avg[_key157] = _val158
@@ -3306,7 +3306,7 @@ class SpoutStats:
(_ktype194, _vtype195, _size193 ) = iprot.readMapBegin()
for _i197 in xrange(_size193):
_key198 = iprot.readString().decode('utf-8')
- _val199 = iprot.readI64();
+ _val199 = iprot.readI64()
_val192[_key198] = _val199
iprot.readMapEnd()
self.acked[_key191] = _val192
@@ -3323,7 +3323,7 @@ class SpoutStats:
(_ktype208, _vtype209, _size207 ) = iprot.readMapBegin()
for _i211 in xrange(_size207):
_key212 = iprot.readString().decode('utf-8')
- _val213 = iprot.readI64();
+ _val213 = iprot.readI64()
_val206[_key212] = _val213
iprot.readMapEnd()
self.failed[_key205] = _val206
@@ -3340,7 +3340,7 @@ class SpoutStats:
(_ktype222, _vtype223, _size221 ) = iprot.readMapBegin()
for _i225 in xrange(_size221):
_key226 = iprot.readString().decode('utf-8')
- _val227 = iprot.readDouble();
+ _val227 = iprot.readDouble()
_val220[_key226] = _val227
iprot.readMapEnd()
self.complete_ms_avg[_key219] = _val220
@@ -3546,7 +3546,7 @@ class ExecutorStats:
(_ktype248, _vtype249, _size247 ) = iprot.readMapBegin()
for _i251 in xrange(_size247):
_key252 = iprot.readString().decode('utf-8')
- _val253 = iprot.readI64();
+ _val253 = iprot.readI64()
_val246[_key252] = _val253
iprot.readMapEnd()
self.emitted[_key245] = _val246
@@ -3563,7 +3563,7 @@ class ExecutorStats:
(_ktype262, _vtype263, _size261 ) = iprot.readMapBegin()
for _i265 in xrange(_size261):
_key266 = iprot.readString().decode('utf-8')
- _val267 = iprot.readI64();
+ _val267 = iprot.readI64()
_val260[_key266] = _val267
iprot.readMapEnd()
self.transferred[_key259] = _val260
@@ -3578,7 +3578,7 @@ class ExecutorStats:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.DOUBLE:
- self.rate = iprot.readDouble();
+ self.rate = iprot.readDouble()
else:
iprot.skip(ftype)
else:
@@ -3685,12 +3685,12 @@ class ExecutorInfo:
break
if fid == 1:
if ftype == TType.I32:
- self.task_start = iprot.readI32();
+ self.task_start = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.I32:
- self.task_end = iprot.readI32();
+ self.task_end = iprot.readI32()
else:
iprot.skip(ftype)
else:
@@ -3796,12 +3796,12 @@ class ExecutorSummary:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.I32:
- self.port = iprot.readI32();
+ self.port = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.I32:
- self.uptime_secs = iprot.readI32();
+ self.uptime_secs = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 7:
@@ -4472,7 +4472,7 @@ class TopologyInfo:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.I32:
- self.uptime_secs = iprot.readI32();
+ self.uptime_secs = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 4:
@@ -4532,37 +4532,37 @@ class TopologyInfo:
iprot.skip(ftype)
elif fid == 515:
if ftype == TType.I32:
- self.replication_count = iprot.readI32();
+ self.replication_count = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 521:
if ftype == TType.DOUBLE:
- self.requested_memonheap = iprot.readDouble();
+ self.requested_memonheap = iprot.readDouble()
else:
iprot.skip(ftype)
elif fid == 522:
if ftype == TType.DOUBLE:
- self.requested_memoffheap = iprot.readDouble();
+ self.requested_memoffheap = iprot.readDouble()
else:
iprot.skip(ftype)
elif fid == 523:
if ftype == TType.DOUBLE:
- self.requested_cpu = iprot.readDouble();
+ self.requested_cpu = iprot.readDouble()
else:
iprot.skip(ftype)
elif fid == 524:
if ftype == TType.DOUBLE:
- self.assigned_memonheap = iprot.readDouble();
+ self.assigned_memonheap = iprot.readDouble()
else:
iprot.skip(ftype)
elif fid == 525:
if ftype == TType.DOUBLE:
- self.assigned_memoffheap = iprot.readDouble();
+ self.assigned_memoffheap = iprot.readDouble()
else:
iprot.skip(ftype)
elif fid == 526:
if ftype == TType.DOUBLE:
- self.assigned_cpu = iprot.readDouble();
+ self.assigned_cpu = iprot.readDouble()
else:
iprot.skip(ftype)
else:
@@ -4731,12 +4731,12 @@ class DebugOptions:
break
if fid == 1:
if ftype == TType.BOOL:
- self.enable = iprot.readBool();
+ self.enable = iprot.readBool()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.DOUBLE:
- self.samplingpct = iprot.readDouble();
+ self.samplingpct = iprot.readDouble()
else:
iprot.skip(ftype)
else:
@@ -4821,32 +4821,32 @@ class CommonAggregateStats:
break
if fid == 1:
if ftype == TType.I32:
- self.num_executors = iprot.readI32();
+ self.num_executors = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.I32:
- self.num_tasks = iprot.readI32();
+ self.num_tasks = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.I64:
- self.emitted = iprot.readI64();
+ self.emitted = iprot.readI64()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.I64:
- self.transferred = iprot.readI64();
+ self.transferred = iprot.readI64()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.I64:
- self.acked = iprot.readI64();
+ self.acked = iprot.readI64()
else:
iprot.skip(ftype)
elif fid == 6:
if ftype == TType.I64:
- self.failed = iprot.readI64();
+ self.failed = iprot.readI64()
else:
iprot.skip(ftype)
else:
@@ -4936,7 +4936,7 @@ class SpoutAggregateStats:
break
if fid == 1:
if ftype == TType.DOUBLE:
- self.complete_latency_ms = iprot.readDouble();
+ self.complete_latency_ms = iprot.readDouble()
else:
iprot.skip(ftype)
else:
@@ -5010,22 +5010,22 @@ class BoltAggregateStats:
break
if fid == 1:
if ftype == TType.DOUBLE:
- self.execute_latency_ms = iprot.readDouble();
+ self.execute_latency_ms = iprot.readDouble()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.DOUBLE:
- self.process_latency_ms = iprot.readDouble();
+ self.process_latency_ms = iprot.readDouble()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.I64:
- self.executed = iprot.readI64();
+ self.executed = iprot.readI64()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.DOUBLE:
- self.capacity = iprot.readDouble();
+ self.capacity = iprot.readDouble()
else:
iprot.skip(ftype)
else:
@@ -5194,7 +5194,7 @@ class ComponentAggregateStats:
break
if fid == 1:
if ftype == TType.I32:
- self.type = iprot.readI32();
+ self.type = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 2:
@@ -5308,7 +5308,7 @@ class TopologyStats:
(_ktype309, _vtype310, _size308 ) = iprot.readMapBegin()
for _i312 in xrange(_size308):
_key313 = iprot.readString().decode('utf-8')
- _val314 = iprot.readI64();
+ _val314 = iprot.readI64()
self.window_to_emitted[_key313] = _val314
iprot.readMapEnd()
else:
@@ -5319,7 +5319,7 @@ class TopologyStats:
(_ktype316, _vtype317, _size315 ) = iprot.readMapBegin()
for _i319 in xrange(_size315):
_key320 = iprot.readString().decode('utf-8')
- _val321 = iprot.readI64();
+ _val321 = iprot.readI64()
self.window_to_transferred[_key320] = _val321
iprot.readMapEnd()
else:
@@ -5330,7 +5330,7 @@ class TopologyStats:
(_ktype323, _vtype324, _size322 ) = iprot.readMapBegin()
for _i326 in xrange(_size322):
_key327 = iprot.readString().decode('utf-8')
- _val328 = iprot.readDouble();
+ _val328 = iprot.readDouble()
self.window_to_complete_latencies_ms[_key327] = _val328
iprot.readMapEnd()
else:
@@ -5341,7 +5341,7 @@ class TopologyStats:
(_ktype330, _vtype331, _size329 ) = iprot.readMapBegin()
for _i333 in xrange(_size329):
_key334 = iprot.readString().decode('utf-8')
- _val335 = iprot.readI64();
+ _val335 = iprot.readI64()
self.window_to_acked[_key334] = _val335
iprot.readMapEnd()
else:
@@ -5352,7 +5352,7 @@ class TopologyStats:
(_ktype337, _vtype338, _size336 ) = iprot.readMapBegin()
for _i340 in xrange(_size336):
_key341 = iprot.readString().decode('utf-8')
- _val342 = iprot.readI64();
+ _val342 = iprot.readI64()
self.window_to_failed[_key341] = _val342
iprot.readMapEnd()
else:
@@ -6034,7 +6034,7 @@ class TopologyPageInfo:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.I32:
- self.uptime_secs = iprot.readI32();
+ self.uptime_secs = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 4:
@@ -6044,17 +6044,17 @@ class TopologyPageInfo:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.I32:
- self.num_tasks = iprot.readI32();
+ self.num_tasks = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 6:
if ftype == TType.I32:
- self.num_workers = iprot.readI32();
+ self.num_workers = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 7:
if ftype == TType.I32:
- self.num_executors = iprot.readI32();
+ self.num_executors = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 8:
@@ -6110,37 +6110,37 @@ class TopologyPageInfo:
iprot.skip(ftype)
elif fid == 15:
if ftype == TType.I32:
- self.replication_count = iprot.readI32();
+ self.replication_count = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 521:
if ftype == TType.DOUBLE:
- self.requested_memonheap = iprot.readDouble();
+ self.requested_memonheap = iprot.readDouble()
else:
iprot.skip(ftype)
elif fid == 522:
if ftype == TType.DOUBLE:
- self.requested_memoffheap = iprot.readDouble();
+ self.requested_memoffheap = iprot.readDouble()
else:
iprot.skip(ftype)
elif fid == 523:
if ftype == TType.DOUBLE:
- self.requested_cpu = iprot.readDouble();
+ self.requested_cpu = iprot.readDouble()
else:
iprot.skip(ftype)
elif fid == 524:
if ftype == TType.DOUBLE:
- self.assigned_memonheap = iprot.readDouble();
+ self.assigned_memonheap = iprot.readDouble()
else:
iprot.skip(ftype)
elif fid == 525:
if ftype == TType.DOUBLE:
- self.assigned_memoffheap = iprot.readDouble();
+ self.assigned_memoffheap = iprot.readDouble()
else:
iprot.skip(ftype)
elif fid == 526:
if ftype == TType.DOUBLE:
- self.assigned_cpu = iprot.readDouble();
+ self.assigned_cpu = iprot.readDouble()
else:
iprot.skip(ftype)
else:
@@ -6442,7 +6442,7 @@ class ComponentPageInfo:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.I32:
- self.component_type = iprot.readI32();
+ self.component_type = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 3:
@@ -6457,12 +6457,12 @@ class ComponentPageInfo:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.I32:
- self.num_executors = iprot.readI32();
+ self.num_executors = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 6:
if ftype == TType.I32:
- self.num_tasks = iprot.readI32();
+ self.num_tasks = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 7:
@@ -6531,7 +6531,7 @@ class ComponentPageInfo:
iprot.skip(ftype)
elif fid == 13:
if ftype == TType.I32:
- self.eventlog_port = iprot.readI32();
+ self.eventlog_port = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 14:
@@ -6699,7 +6699,7 @@ class KillOptions:
break
if fid == 1:
if ftype == TType.I32:
- self.wait_secs = iprot.readI32();
+ self.wait_secs = iprot.readI32()
else:
iprot.skip(ftype)
else:
@@ -6770,12 +6770,12 @@ class RebalanceOptions:
break
if fid == 1:
if ftype == TType.I32:
- self.wait_secs = iprot.readI32();
+ self.wait_secs = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.I32:
- self.num_workers = iprot.readI32();
+ self.num_workers = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 3:
@@ -6784,7 +6784,7 @@ class RebalanceOptions:
(_ktype413, _vtype414, _size412 ) = iprot.readMapBegin()
for _i416 in xrange(_size412):
_key417 = iprot.readString().decode('utf-8')
- _val418 = iprot.readI32();
+ _val418 = iprot.readI32()
self.num_executors[_key417] = _val418
iprot.readMapEnd()
else:
@@ -6945,7 +6945,7 @@ class SubmitOptions:
break
if fid == 1:
if ftype == TType.I32:
- self.initial_status = iprot.readI32();
+ self.initial_status = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 2:
@@ -7047,7 +7047,7 @@ class SupervisorInfo:
break
if fid == 1:
if ftype == TType.I64:
- self.time_secs = iprot.readI64();
+ self.time_secs = iprot.readI64()
else:
iprot.skip(ftype)
elif fid == 2:
@@ -7065,7 +7065,7 @@ class SupervisorInfo:
self.used_ports = []
(_etype433, _size430) = iprot.readListBegin()
for _i434 in xrange(_size430):
- _elem435 = iprot.readI64();
+ _elem435 = iprot.readI64()
self.used_ports.append(_elem435)
iprot.readListEnd()
else:
@@ -7075,7 +7075,7 @@ class SupervisorInfo:
self.meta = []
(_etype439, _size436) = iprot.readListBegin()
for _i440 in xrange(_size436):
- _elem441 = iprot.readI64();
+ _elem441 = iprot.readI64()
self.meta.append(_elem441)
iprot.readListEnd()
else:
@@ -7093,7 +7093,7 @@ class SupervisorInfo:
iprot.skip(ftype)
elif fid == 7:
if ftype == TType.I64:
- self.uptime_secs = iprot.readI64();
+ self.uptime_secs = iprot.readI64()
else:
iprot.skip(ftype)
elif fid == 8:
@@ -7107,7 +7107,7 @@ class SupervisorInfo:
(_ktype450, _vtype451, _size449 ) = iprot.readMapBegin()
for _i453 in xrange(_size449):
_key454 = iprot.readString().decode('utf-8')
- _val455 = iprot.readDouble();
+ _val455 = iprot.readDouble()
self.resources_map[_key454] = _val455
iprot.readMapEnd()
else:
@@ -7243,7 +7243,7 @@ class NodeInfo:
self.port = set()
(_etype465, _size462) = iprot.readSetBegin()
for _i466 in xrange(_size462):
- _elem467 = iprot.readI64();
+ _elem467 = iprot.readI64()
self.port.add(_elem467)
iprot.readSetEnd()
else:
@@ -7328,17 +7328,17 @@ class WorkerResources:
break
if fid == 1:
if ftype == TType.DOUBLE:
- self.mem_on_heap = iprot.readDouble();
+ self.mem_on_heap = iprot.readDouble()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.DOUBLE:
- self.mem_off_heap = iprot.readDouble();
+ self.mem_off_heap = iprot.readDouble()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.DOUBLE:
- self.cpu = iprot.readDouble();
+ self.cpu = iprot.readDouble()
else:
iprot.skip(ftype)
else:
@@ -7463,7 +7463,7 @@ class Assignment:
_key481 = []
(_etype486, _size483) = iprot.readListBegin()
for _i487 in xrange(_size483):
- _elem488 = iprot.readI64();
+ _elem488 = iprot.readI64()
_key481.append(_elem488)
iprot.readListEnd()
_val482 = NodeInfo()
@@ -7480,10 +7480,10 @@ class Assignment:
_key494 = []
(_etype499, _size496) = iprot.readListBegin()
for _i500 in xrange(_size496):
- _elem501 = iprot.readI64();
+ _elem501 = iprot.readI64()
_key494.append(_elem501)
iprot.readListEnd()
- _val495 = iprot.readI64();
+ _val495 = iprot.readI64()
self.executor_start_time_secs[_key494] = _val495
iprot.readMapEnd()
else:
@@ -7716,12 +7716,12 @@ class StormBase:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.I32:
- self.status = iprot.readI32();
+ self.status = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.I32:
- self.num_workers = iprot.readI32();
+ self.num_workers = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 4:
@@ -7730,14 +7730,14 @@ class StormBase:
(_ktype520, _vtype521, _size519 ) = iprot.readMapBegin()
for _i523 in xrange(_size519):
_key524 = iprot.readString().decode('utf-8')
- _val525 = iprot.readI32();
+ _val525 = iprot.readI32()
self.component_executors[_key524] = _val525
iprot.readMapEnd()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.I32:
- self.launch_time_secs = iprot.readI32();
+ self.launch_time_secs = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 6:
@@ -7753,7 +7753,7 @@ class StormBase:
iprot.skip(ftype)
elif fid == 8:
if ftype == TType.I32:
- self.prev_status = iprot.readI32();
+ self.prev_status = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 9:
@@ -7911,12 +7911,12 @@ class ClusterWorkerHeartbeat:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.I32:
- self.time_secs = iprot.readI32();
+ self.time_secs = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.I32:
- self.uptime_secs = iprot.readI32();
+ self.uptime_secs = iprot.readI32()
else:
iprot.skip(ftype)
else:
@@ -8016,7 +8016,7 @@ class ThriftSerializedObject:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.bits = iprot.readString();
+ self.bits = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -8344,7 +8344,7 @@ class LSApprovedWorkers:
(_ktype563, _vtype564, _size562 ) = iprot.readMapBegin()
for _i566 in xrange(_size562):
_key567 = iprot.readString().decode('utf-8')
- _val568 = iprot.readI32();
+ _val568 = iprot.readI32()
self.approved_workers[_key567] = _val568
iprot.readMapEnd()
else:
@@ -8420,7 +8420,7 @@ class LSSupervisorAssignments:
self.assignments = {}
(_ktype572, _vtype573, _size571 ) = iprot.readMapBegin()
for _i575 in xrange(_size571):
- _key576 = iprot.readI32();
+ _key576 = iprot.readI32()
_val577 = LocalAssignment()
_val577.read(iprot)
self.assignments[_key576] = _val577
@@ -8504,7 +8504,7 @@ class LSWorkerHeartbeat:
break
if fid == 1:
if ftype == TType.I32:
- self.time_secs = iprot.readI32();
+ self.time_secs = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 2:
@@ -8525,7 +8525,7 @@ class LSWorkerHeartbeat:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.I32:
- self.port = iprot.readI32();
+ self.port = iprot.readI32()
else:
iprot.skip(ftype)
else:
@@ -8630,7 +8630,7 @@ class LSTopoHistory:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.I64:
- self.time_stamp = iprot.readI64();
+ self.time_stamp = iprot.readI64()
else:
iprot.skip(ftype)
elif fid == 3:
@@ -8832,12 +8832,12 @@ class ProfileRequest:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.I32:
- self.action = iprot.readI32();
+ self.action = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.I64:
- self.time_stamp = iprot.readI64();
+ self.time_stamp = iprot.readI64()
else:
iprot.skip(ftype)
else:
@@ -8916,7 +8916,7 @@ class GetInfoOptions:
break
if fid == 1:
if ftype == TType.I32:
- self.num_err_choice = iprot.readI32();
+ self.num_err_choice = iprot.readI32()
else:
iprot.skip(ftype)
else:
@@ -8993,7 +8993,7 @@ class LogLevel:
break
if fid == 1:
if ftype == TType.I32:
- self.action = iprot.readI32();
+ self.action = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 2:
@@ -9003,12 +9003,12 @@ class LogLevel:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.I32:
- self.reset_log_level_timeout_secs = iprot.readI32();
+ self.reset_log_level_timeout_secs = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.I64:
- self.reset_log_level_timeout_epoch = iprot.readI64();
+ self.reset_log_level_timeout_epoch = iprot.readI64()
else:
iprot.skip(ftype)
elif fid == 5:
[2/6] storm git commit: Upgrading to thrift 0.9.3
Posted by bo...@apache.org.
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/SpoutAggregateStats.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/SpoutAggregateStats.java b/storm-core/src/jvm/backtype/storm/generated/SpoutAggregateStats.java
index a8d6ec7..053db0a 100644
--- a/storm-core/src/jvm/backtype/storm/generated/SpoutAggregateStats.java
+++ b/storm-core/src/jvm/backtype/storm/generated/SpoutAggregateStats.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class SpoutAggregateStats implements org.apache.thrift.TBase<SpoutAggregateStats, SpoutAggregateStats._Fields>, java.io.Serializable, Cloneable, Comparable<SpoutAggregateStats> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("SpoutAggregateStats");
@@ -195,7 +195,7 @@ public class SpoutAggregateStats implements org.apache.thrift.TBase<SpoutAggrega
public Object getFieldValue(_Fields field) {
switch (field) {
case COMPLETE_LATENCY_MS:
- return Double.valueOf(get_complete_latency_ms());
+ return get_complete_latency_ms();
}
throw new IllegalStateException();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/SpoutSpec.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/SpoutSpec.java b/storm-core/src/jvm/backtype/storm/generated/SpoutSpec.java
index 3fc45cf..492cc36 100644
--- a/storm-core/src/jvm/backtype/storm/generated/SpoutSpec.java
+++ b/storm-core/src/jvm/backtype/storm/generated/SpoutSpec.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class SpoutSpec implements org.apache.thrift.TBase<SpoutSpec, SpoutSpec._Fields>, java.io.Serializable, Cloneable, Comparable<SpoutSpec> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("SpoutSpec");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/SpoutStats.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/SpoutStats.java b/storm-core/src/jvm/backtype/storm/generated/SpoutStats.java
index 478143f..3f17136 100644
--- a/storm-core/src/jvm/backtype/storm/generated/SpoutStats.java
+++ b/storm-core/src/jvm/backtype/storm/generated/SpoutStats.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class SpoutStats implements org.apache.thrift.TBase<SpoutStats, SpoutStats._Fields>, java.io.Serializable, Cloneable, Comparable<SpoutStats> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("SpoutStats");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/StateSpoutSpec.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/StateSpoutSpec.java b/storm-core/src/jvm/backtype/storm/generated/StateSpoutSpec.java
index 530b7ca..24b3e5c 100644
--- a/storm-core/src/jvm/backtype/storm/generated/StateSpoutSpec.java
+++ b/storm-core/src/jvm/backtype/storm/generated/StateSpoutSpec.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class StateSpoutSpec implements org.apache.thrift.TBase<StateSpoutSpec, StateSpoutSpec._Fields>, java.io.Serializable, Cloneable, Comparable<StateSpoutSpec> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("StateSpoutSpec");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/StormBase.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/StormBase.java b/storm-core/src/jvm/backtype/storm/generated/StormBase.java
index f4af67a..2d8bf15 100644
--- a/storm-core/src/jvm/backtype/storm/generated/StormBase.java
+++ b/storm-core/src/jvm/backtype/storm/generated/StormBase.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._Fields>, java.io.Serializable, Cloneable, Comparable<StormBase> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("StormBase");
@@ -611,13 +611,13 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
return get_status();
case NUM_WORKERS:
- return Integer.valueOf(get_num_workers());
+ return get_num_workers();
case COMPONENT_EXECUTORS:
return get_component_executors();
case LAUNCH_TIME_SECS:
- return Integer.valueOf(get_launch_time_secs());
+ return get_launch_time_secs();
case OWNER:
return get_owner();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/StormTopology.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/StormTopology.java b/storm-core/src/jvm/backtype/storm/generated/StormTopology.java
index 9b96fa3..81fe93e 100644
--- a/storm-core/src/jvm/backtype/storm/generated/StormTopology.java
+++ b/storm-core/src/jvm/backtype/storm/generated/StormTopology.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class StormTopology implements org.apache.thrift.TBase<StormTopology, StormTopology._Fields>, java.io.Serializable, Cloneable, Comparable<StormTopology> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("StormTopology");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/StreamInfo.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/StreamInfo.java b/storm-core/src/jvm/backtype/storm/generated/StreamInfo.java
index e3b0fdb..caa1887 100644
--- a/storm-core/src/jvm/backtype/storm/generated/StreamInfo.java
+++ b/storm-core/src/jvm/backtype/storm/generated/StreamInfo.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInfo._Fields>, java.io.Serializable, Cloneable, Comparable<StreamInfo> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("StreamInfo");
@@ -266,7 +266,7 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
return get_output_fields();
case DIRECT:
- return Boolean.valueOf(is_direct());
+ return is_direct();
}
throw new IllegalStateException();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/SubmitOptions.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/SubmitOptions.java b/storm-core/src/jvm/backtype/storm/generated/SubmitOptions.java
index 358468a..214ded0 100644
--- a/storm-core/src/jvm/backtype/storm/generated/SubmitOptions.java
+++ b/storm-core/src/jvm/backtype/storm/generated/SubmitOptions.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class SubmitOptions implements org.apache.thrift.TBase<SubmitOptions, SubmitOptions._Fields>, java.io.Serializable, Cloneable, Comparable<SubmitOptions> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("SubmitOptions");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/SupervisorInfo.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/SupervisorInfo.java b/storm-core/src/jvm/backtype/storm/generated/SupervisorInfo.java
index 6d68927..dcfb353 100644
--- a/storm-core/src/jvm/backtype/storm/generated/SupervisorInfo.java
+++ b/storm-core/src/jvm/backtype/storm/generated/SupervisorInfo.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class SupervisorInfo implements org.apache.thrift.TBase<SupervisorInfo, SupervisorInfo._Fields>, java.io.Serializable, Cloneable, Comparable<SupervisorInfo> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("SupervisorInfo");
@@ -602,7 +602,7 @@ public class SupervisorInfo implements org.apache.thrift.TBase<SupervisorInfo, S
public Object getFieldValue(_Fields field) {
switch (field) {
case TIME_SECS:
- return Long.valueOf(get_time_secs());
+ return get_time_secs();
case HOSTNAME:
return get_hostname();
@@ -620,7 +620,7 @@ public class SupervisorInfo implements org.apache.thrift.TBase<SupervisorInfo, S
return get_scheduler_meta();
case UPTIME_SECS:
- return Long.valueOf(get_uptime_secs());
+ return get_uptime_secs();
case VERSION:
return get_version();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/SupervisorSummary.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/SupervisorSummary.java b/storm-core/src/jvm/backtype/storm/generated/SupervisorSummary.java
index 7e36d0f..2c3f330 100644
--- a/storm-core/src/jvm/backtype/storm/generated/SupervisorSummary.java
+++ b/storm-core/src/jvm/backtype/storm/generated/SupervisorSummary.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class SupervisorSummary implements org.apache.thrift.TBase<SupervisorSummary, SupervisorSummary._Fields>, java.io.Serializable, Cloneable, Comparable<SupervisorSummary> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("SupervisorSummary");
@@ -483,13 +483,13 @@ public class SupervisorSummary implements org.apache.thrift.TBase<SupervisorSumm
return get_host();
case UPTIME_SECS:
- return Integer.valueOf(get_uptime_secs());
+ return get_uptime_secs();
case NUM_WORKERS:
- return Integer.valueOf(get_num_workers());
+ return get_num_workers();
case NUM_USED_WORKERS:
- return Integer.valueOf(get_num_used_workers());
+ return get_num_used_workers();
case SUPERVISOR_ID:
return get_supervisor_id();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/ThriftSerializedObject.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ThriftSerializedObject.java b/storm-core/src/jvm/backtype/storm/generated/ThriftSerializedObject.java
index 4b2bc63..810bea8 100644
--- a/storm-core/src/jvm/backtype/storm/generated/ThriftSerializedObject.java
+++ b/storm-core/src/jvm/backtype/storm/generated/ThriftSerializedObject.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class ThriftSerializedObject implements org.apache.thrift.TBase<ThriftSerializedObject, ThriftSerializedObject._Fields>, java.io.Serializable, Cloneable, Comparable<ThriftSerializedObject> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ThriftSerializedObject");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/TopologyActionOptions.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/TopologyActionOptions.java b/storm-core/src/jvm/backtype/storm/generated/TopologyActionOptions.java
index c6fea05..6e6d704 100644
--- a/storm-core/src/jvm/backtype/storm/generated/TopologyActionOptions.java
+++ b/storm-core/src/jvm/backtype/storm/generated/TopologyActionOptions.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/TopologyHistoryInfo.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/TopologyHistoryInfo.java b/storm-core/src/jvm/backtype/storm/generated/TopologyHistoryInfo.java
index 8afaca3..cf9bff1 100644
--- a/storm-core/src/jvm/backtype/storm/generated/TopologyHistoryInfo.java
+++ b/storm-core/src/jvm/backtype/storm/generated/TopologyHistoryInfo.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-11-4")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class TopologyHistoryInfo implements org.apache.thrift.TBase<TopologyHistoryInfo, TopologyHistoryInfo._Fields>, java.io.Serializable, Cloneable, Comparable<TopologyHistoryInfo> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TopologyHistoryInfo");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/TopologyInfo.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/TopologyInfo.java b/storm-core/src/jvm/backtype/storm/generated/TopologyInfo.java
index 9a4111f..f7c44b4 100644
--- a/storm-core/src/jvm/backtype/storm/generated/TopologyInfo.java
+++ b/storm-core/src/jvm/backtype/storm/generated/TopologyInfo.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-29")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, TopologyInfo._Fields>, java.io.Serializable, Cloneable, Comparable<TopologyInfo> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TopologyInfo");
@@ -916,7 +916,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol
return get_name();
case UPTIME_SECS:
- return Integer.valueOf(get_uptime_secs());
+ return get_uptime_secs();
case EXECUTORS:
return get_executors();
@@ -937,25 +937,25 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol
return get_owner();
case REPLICATION_COUNT:
- return Integer.valueOf(get_replication_count());
+ return get_replication_count();
case REQUESTED_MEMONHEAP:
- return Double.valueOf(get_requested_memonheap());
+ return get_requested_memonheap();
case REQUESTED_MEMOFFHEAP:
- return Double.valueOf(get_requested_memoffheap());
+ return get_requested_memoffheap();
case REQUESTED_CPU:
- return Double.valueOf(get_requested_cpu());
+ return get_requested_cpu();
case ASSIGNED_MEMONHEAP:
- return Double.valueOf(get_assigned_memonheap());
+ return get_assigned_memonheap();
case ASSIGNED_MEMOFFHEAP:
- return Double.valueOf(get_assigned_memoffheap());
+ return get_assigned_memoffheap();
case ASSIGNED_CPU:
- return Double.valueOf(get_assigned_cpu());
+ return get_assigned_cpu();
}
throw new IllegalStateException();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/TopologyInitialStatus.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/TopologyInitialStatus.java b/storm-core/src/jvm/backtype/storm/generated/TopologyInitialStatus.java
index a8d6c9e..7117bd4 100644
--- a/storm-core/src/jvm/backtype/storm/generated/TopologyInitialStatus.java
+++ b/storm-core/src/jvm/backtype/storm/generated/TopologyInitialStatus.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/TopologyPageInfo.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/TopologyPageInfo.java b/storm-core/src/jvm/backtype/storm/generated/TopologyPageInfo.java
index 257ec9d..4813fde 100644
--- a/storm-core/src/jvm/backtype/storm/generated/TopologyPageInfo.java
+++ b/storm-core/src/jvm/backtype/storm/generated/TopologyPageInfo.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-29")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInfo, TopologyPageInfo._Fields>, java.io.Serializable, Cloneable, Comparable<TopologyPageInfo> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TopologyPageInfo");
@@ -1088,19 +1088,19 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
return get_name();
case UPTIME_SECS:
- return Integer.valueOf(get_uptime_secs());
+ return get_uptime_secs();
case STATUS:
return get_status();
case NUM_TASKS:
- return Integer.valueOf(get_num_tasks());
+ return get_num_tasks();
case NUM_WORKERS:
- return Integer.valueOf(get_num_workers());
+ return get_num_workers();
case NUM_EXECUTORS:
- return Integer.valueOf(get_num_executors());
+ return get_num_executors();
case TOPOLOGY_CONF:
return get_topology_conf();
@@ -1124,25 +1124,25 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
return get_debug_options();
case REPLICATION_COUNT:
- return Integer.valueOf(get_replication_count());
+ return get_replication_count();
case REQUESTED_MEMONHEAP:
- return Double.valueOf(get_requested_memonheap());
+ return get_requested_memonheap();
case REQUESTED_MEMOFFHEAP:
- return Double.valueOf(get_requested_memoffheap());
+ return get_requested_memoffheap();
case REQUESTED_CPU:
- return Double.valueOf(get_requested_cpu());
+ return get_requested_cpu();
case ASSIGNED_MEMONHEAP:
- return Double.valueOf(get_assigned_memonheap());
+ return get_assigned_memonheap();
case ASSIGNED_MEMOFFHEAP:
- return Double.valueOf(get_assigned_memoffheap());
+ return get_assigned_memoffheap();
case ASSIGNED_CPU:
- return Double.valueOf(get_assigned_cpu());
+ return get_assigned_cpu();
}
throw new IllegalStateException();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/TopologyStats.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/TopologyStats.java b/storm-core/src/jvm/backtype/storm/generated/TopologyStats.java
index 0ff01de..99f3922 100644
--- a/storm-core/src/jvm/backtype/storm/generated/TopologyStats.java
+++ b/storm-core/src/jvm/backtype/storm/generated/TopologyStats.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, TopologyStats._Fields>, java.io.Serializable, Cloneable, Comparable<TopologyStats> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TopologyStats");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/TopologyStatus.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/TopologyStatus.java b/storm-core/src/jvm/backtype/storm/generated/TopologyStatus.java
index 8183ab2..3866a8c 100644
--- a/storm-core/src/jvm/backtype/storm/generated/TopologyStatus.java
+++ b/storm-core/src/jvm/backtype/storm/generated/TopologyStatus.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/TopologySummary.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/TopologySummary.java b/storm-core/src/jvm/backtype/storm/generated/TopologySummary.java
index 7bb2e44..5387e62 100644
--- a/storm-core/src/jvm/backtype/storm/generated/TopologySummary.java
+++ b/storm-core/src/jvm/backtype/storm/generated/TopologySummary.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-29")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, TopologySummary._Fields>, java.io.Serializable, Cloneable, Comparable<TopologySummary> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TopologySummary");
@@ -844,16 +844,16 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary,
return get_name();
case NUM_TASKS:
- return Integer.valueOf(get_num_tasks());
+ return get_num_tasks();
case NUM_EXECUTORS:
- return Integer.valueOf(get_num_executors());
+ return get_num_executors();
case NUM_WORKERS:
- return Integer.valueOf(get_num_workers());
+ return get_num_workers();
case UPTIME_SECS:
- return Integer.valueOf(get_uptime_secs());
+ return get_uptime_secs();
case STATUS:
return get_status();
@@ -865,25 +865,25 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary,
return get_owner();
case REPLICATION_COUNT:
- return Integer.valueOf(get_replication_count());
+ return get_replication_count();
case REQUESTED_MEMONHEAP:
- return Double.valueOf(get_requested_memonheap());
+ return get_requested_memonheap();
case REQUESTED_MEMOFFHEAP:
- return Double.valueOf(get_requested_memoffheap());
+ return get_requested_memoffheap();
case REQUESTED_CPU:
- return Double.valueOf(get_requested_cpu());
+ return get_requested_cpu();
case ASSIGNED_MEMONHEAP:
- return Double.valueOf(get_assigned_memonheap());
+ return get_assigned_memonheap();
case ASSIGNED_MEMOFFHEAP:
- return Double.valueOf(get_assigned_memoffheap());
+ return get_assigned_memoffheap();
case ASSIGNED_CPU:
- return Double.valueOf(get_assigned_cpu());
+ return get_assigned_cpu();
}
throw new IllegalStateException();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/WorkerResources.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/WorkerResources.java b/storm-core/src/jvm/backtype/storm/generated/WorkerResources.java
index 7cfadd7..3af22fb 100644
--- a/storm-core/src/jvm/backtype/storm/generated/WorkerResources.java
+++ b/storm-core/src/jvm/backtype/storm/generated/WorkerResources.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class WorkerResources implements org.apache.thrift.TBase<WorkerResources, WorkerResources._Fields>, java.io.Serializable, Cloneable, Comparable<WorkerResources> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("WorkerResources");
@@ -277,13 +277,13 @@ public class WorkerResources implements org.apache.thrift.TBase<WorkerResources,
public Object getFieldValue(_Fields field) {
switch (field) {
case MEM_ON_HEAP:
- return Double.valueOf(get_mem_on_heap());
+ return get_mem_on_heap();
case MEM_OFF_HEAP:
- return Double.valueOf(get_mem_off_heap());
+ return get_mem_off_heap();
case CPU:
- return Double.valueOf(get_cpu());
+ return get_cpu();
}
throw new IllegalStateException();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/security/auth/SimpleTransportPlugin.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/security/auth/SimpleTransportPlugin.java b/storm-core/src/jvm/backtype/storm/security/auth/SimpleTransportPlugin.java
index 7a0a6f2..b73c585 100644
--- a/storm-core/src/jvm/backtype/storm/security/auth/SimpleTransportPlugin.java
+++ b/storm-core/src/jvm/backtype/storm/security/auth/SimpleTransportPlugin.java
@@ -73,7 +73,7 @@ public class SimpleTransportPlugin implements ITransportPlugin {
THsHaServer.Args server_args = new THsHaServer.Args(serverTransport).
processor(new SimpleWrapProcessor(processor)).
- workerThreads(numWorkerThreads).
+ maxWorkerThreads(numWorkerThreads).
protocolFactory(new TBinaryProtocol.Factory(false, true, maxBufferSize, -1));
if (queueSize != null) {
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/py/storm/DistributedRPC-remote
----------------------------------------------------------------------
diff --git a/storm-core/src/py/storm/DistributedRPC-remote b/storm-core/src/py/storm/DistributedRPC-remote
index 3d06d07..90f894a 100644
--- a/storm-core/src/py/storm/DistributedRPC-remote
+++ b/storm-core/src/py/storm/DistributedRPC-remote
@@ -18,7 +18,7 @@
#!/usr/bin/env python
#
-# Autogenerated by Thrift Compiler (0.9.2)
+# Autogenerated by Thrift Compiler (0.9.3)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/py/storm/DistributedRPC.py
----------------------------------------------------------------------
diff --git a/storm-core/src/py/storm/DistributedRPC.py b/storm-core/src/py/storm/DistributedRPC.py
index 330499c..225c57e 100644
--- a/storm-core/src/py/storm/DistributedRPC.py
+++ b/storm-core/src/py/storm/DistributedRPC.py
@@ -17,7 +17,7 @@
# limitations under the License.
#
-# Autogenerated by Thrift Compiler (0.9.2)
+# Autogenerated by Thrift Compiler (0.9.3)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
@@ -25,6 +25,7 @@
#
from thrift.Thrift import TType, TMessageType, TException, TApplicationException
+import logging
from ttypes import *
from thrift.Thrift import TProcessor
from thrift.transport import TTransport
@@ -87,7 +88,7 @@ class Client(Iface):
raise result.e
if result.aze is not None:
raise result.aze
- raise TApplicationException(TApplicationException.MISSING_RESULT, "execute failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "execute failed: unknown result")
class Processor(Iface, TProcessor):
@@ -118,11 +119,20 @@ class Processor(Iface, TProcessor):
result = execute_result()
try:
result.success = self._handler.execute(args.functionName, args.funcArgs)
- except DRPCExecutionException, e:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except DRPCExecutionException as e:
+ msg_type = TMessageType.REPLY
result.e = e
- except AuthorizationException, aze:
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("execute", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("execute", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/py/storm/DistributedRPCInvocations-remote
----------------------------------------------------------------------
diff --git a/storm-core/src/py/storm/DistributedRPCInvocations-remote b/storm-core/src/py/storm/DistributedRPCInvocations-remote
index 9dd50cd..01435b6 100644
--- a/storm-core/src/py/storm/DistributedRPCInvocations-remote
+++ b/storm-core/src/py/storm/DistributedRPCInvocations-remote
@@ -18,7 +18,7 @@
#!/usr/bin/env python
#
-# Autogenerated by Thrift Compiler (0.9.2)
+# Autogenerated by Thrift Compiler (0.9.3)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/py/storm/DistributedRPCInvocations.py
----------------------------------------------------------------------
diff --git a/storm-core/src/py/storm/DistributedRPCInvocations.py b/storm-core/src/py/storm/DistributedRPCInvocations.py
index 493fcc7..207fa9d 100644
--- a/storm-core/src/py/storm/DistributedRPCInvocations.py
+++ b/storm-core/src/py/storm/DistributedRPCInvocations.py
@@ -17,7 +17,7 @@
# limitations under the License.
#
-# Autogenerated by Thrift Compiler (0.9.2)
+# Autogenerated by Thrift Compiler (0.9.3)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
@@ -25,6 +25,7 @@
#
from thrift.Thrift import TType, TMessageType, TException, TApplicationException
+import logging
from ttypes import *
from thrift.Thrift import TProcessor
from thrift.transport import TTransport
@@ -130,7 +131,7 @@ class Client(Iface):
return result.success
if result.aze is not None:
raise result.aze
- raise TApplicationException(TApplicationException.MISSING_RESULT, "fetchRequest failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "fetchRequest failed: unknown result")
def failRequest(self, id):
"""
@@ -194,9 +195,17 @@ class Processor(Iface, TProcessor):
result = result_result()
try:
self._handler.result(args.id, args.result)
- except AuthorizationException, aze:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("result", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("result", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -208,9 +217,17 @@ class Processor(Iface, TProcessor):
result = fetchRequest_result()
try:
result.success = self._handler.fetchRequest(args.functionName)
- except AuthorizationException, aze:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("fetchRequest", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("fetchRequest", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -222,9 +239,17 @@ class Processor(Iface, TProcessor):
result = failRequest_result()
try:
self._handler.failRequest(args.id)
- except AuthorizationException, aze:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("failRequest", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("failRequest", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/py/storm/Nimbus-remote
----------------------------------------------------------------------
diff --git a/storm-core/src/py/storm/Nimbus-remote b/storm-core/src/py/storm/Nimbus-remote
index 8f0dbc9..63e7dce 100644
--- a/storm-core/src/py/storm/Nimbus-remote
+++ b/storm-core/src/py/storm/Nimbus-remote
@@ -18,7 +18,7 @@
#!/usr/bin/env python
#
-# Autogenerated by Thrift Compiler (0.9.2)
+# Autogenerated by Thrift Compiler (0.9.3)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/py/storm/Nimbus.py
----------------------------------------------------------------------
diff --git a/storm-core/src/py/storm/Nimbus.py b/storm-core/src/py/storm/Nimbus.py
index a2d4c0b..14e5f2e 100644
--- a/storm-core/src/py/storm/Nimbus.py
+++ b/storm-core/src/py/storm/Nimbus.py
@@ -17,7 +17,7 @@
# limitations under the License.
#
-# Autogenerated by Thrift Compiler (0.9.2)
+# Autogenerated by Thrift Compiler (0.9.3)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
@@ -25,6 +25,7 @@
#
from thrift.Thrift import TType, TMessageType, TException, TApplicationException
+import logging
from ttypes import *
from thrift.Thrift import TProcessor
from thrift.transport import TTransport
@@ -577,7 +578,7 @@ class Client(Iface):
iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getLogConfig failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getLogConfig failed: unknown result")
def debug(self, name, component, enable, samplingPercentage):
"""
@@ -688,7 +689,7 @@ class Client(Iface):
iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getComponentPendingProfileActions failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getComponentPendingProfileActions failed: unknown result")
def uploadNewCredentials(self, name, creds):
"""
@@ -753,7 +754,7 @@ class Client(Iface):
return result.success
if result.aze is not None:
raise result.aze
- raise TApplicationException(TApplicationException.MISSING_RESULT, "beginFileUpload failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "beginFileUpload failed: unknown result")
def uploadChunk(self, location, chunk):
"""
@@ -850,7 +851,7 @@ class Client(Iface):
return result.success
if result.aze is not None:
raise result.aze
- raise TApplicationException(TApplicationException.MISSING_RESULT, "beginFileDownload failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "beginFileDownload failed: unknown result")
def downloadChunk(self, id):
"""
@@ -883,7 +884,7 @@ class Client(Iface):
return result.success
if result.aze is not None:
raise result.aze
- raise TApplicationException(TApplicationException.MISSING_RESULT, "downloadChunk failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "downloadChunk failed: unknown result")
def getNimbusConf(self):
self.send_getNimbusConf()
@@ -911,7 +912,7 @@ class Client(Iface):
return result.success
if result.aze is not None:
raise result.aze
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getNimbusConf failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getNimbusConf failed: unknown result")
def getClusterInfo(self):
self.send_getClusterInfo()
@@ -939,7 +940,7 @@ class Client(Iface):
return result.success
if result.aze is not None:
raise result.aze
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getClusterInfo failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getClusterInfo failed: unknown result")
def getTopologyInfo(self, id):
"""
@@ -974,7 +975,7 @@ class Client(Iface):
raise result.e
if result.aze is not None:
raise result.aze
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getTopologyInfo failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getTopologyInfo failed: unknown result")
def getTopologyInfoWithOpts(self, id, options):
"""
@@ -1011,7 +1012,7 @@ class Client(Iface):
raise result.e
if result.aze is not None:
raise result.aze
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getTopologyInfoWithOpts failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getTopologyInfoWithOpts failed: unknown result")
def getTopologyPageInfo(self, id, window, is_include_sys):
"""
@@ -1050,7 +1051,7 @@ class Client(Iface):
raise result.e
if result.aze is not None:
raise result.aze
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getTopologyPageInfo failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getTopologyPageInfo failed: unknown result")
def getComponentPageInfo(self, topology_id, component_id, window, is_include_sys):
"""
@@ -1091,7 +1092,7 @@ class Client(Iface):
raise result.e
if result.aze is not None:
raise result.aze
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getComponentPageInfo failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getComponentPageInfo failed: unknown result")
def getTopologyConf(self, id):
"""
@@ -1126,7 +1127,7 @@ class Client(Iface):
raise result.e
if result.aze is not None:
raise result.aze
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getTopologyConf failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getTopologyConf failed: unknown result")
def getTopology(self, id):
"""
@@ -1163,7 +1164,7 @@ class Client(Iface):
raise result.e
if result.aze is not None:
raise result.aze
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getTopology failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getTopology failed: unknown result")
def getUserTopology(self, id):
"""
@@ -1200,7 +1201,7 @@ class Client(Iface):
raise result.e
if result.aze is not None:
raise result.aze
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getUserTopology failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getUserTopology failed: unknown result")
def getTopologyHistory(self, user):
"""
@@ -1233,7 +1234,7 @@ class Client(Iface):
return result.success
if result.aze is not None:
raise result.aze
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getTopologyHistory failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getTopologyHistory failed: unknown result")
class Processor(Iface, TProcessor):
@@ -1291,13 +1292,23 @@ class Processor(Iface, TProcessor):
result = submitTopology_result()
try:
self._handler.submitTopology(args.name, args.uploadedJarLocation, args.jsonConf, args.topology)
- except AlreadyAliveException, e:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except AlreadyAliveException as e:
+ msg_type = TMessageType.REPLY
result.e = e
- except InvalidTopologyException, ite:
+ except InvalidTopologyException as ite:
+ msg_type = TMessageType.REPLY
result.ite = ite
- except AuthorizationException, aze:
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("submitTopology", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("submitTopology", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1309,13 +1320,23 @@ class Processor(Iface, TProcessor):
result = submitTopologyWithOpts_result()
try:
self._handler.submitTopologyWithOpts(args.name, args.uploadedJarLocation, args.jsonConf, args.topology, args.options)
- except AlreadyAliveException, e:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except AlreadyAliveException as e:
+ msg_type = TMessageType.REPLY
result.e = e
- except InvalidTopologyException, ite:
+ except InvalidTopologyException as ite:
+ msg_type = TMessageType.REPLY
result.ite = ite
- except AuthorizationException, aze:
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("submitTopologyWithOpts", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("submitTopologyWithOpts", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1327,11 +1348,20 @@ class Processor(Iface, TProcessor):
result = killTopology_result()
try:
self._handler.killTopology(args.name)
- except NotAliveException, e:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except NotAliveException as e:
+ msg_type = TMessageType.REPLY
result.e = e
- except AuthorizationException, aze:
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("killTopology", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("killTopology", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1343,11 +1373,20 @@ class Processor(Iface, TProcessor):
result = killTopologyWithOpts_result()
try:
self._handler.killTopologyWithOpts(args.name, args.options)
- except NotAliveException, e:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except NotAliveException as e:
+ msg_type = TMessageType.REPLY
result.e = e
- except AuthorizationException, aze:
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("killTopologyWithOpts", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("killTopologyWithOpts", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1359,11 +1398,20 @@ class Processor(Iface, TProcessor):
result = activate_result()
try:
self._handler.activate(args.name)
- except NotAliveException, e:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except NotAliveException as e:
+ msg_type = TMessageType.REPLY
result.e = e
- except AuthorizationException, aze:
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("activate", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("activate", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1375,11 +1423,20 @@ class Processor(Iface, TProcessor):
result = deactivate_result()
try:
self._handler.deactivate(args.name)
- except NotAliveException, e:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except NotAliveException as e:
+ msg_type = TMessageType.REPLY
result.e = e
- except AuthorizationException, aze:
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("deactivate", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("deactivate", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1391,13 +1448,23 @@ class Processor(Iface, TProcessor):
result = rebalance_result()
try:
self._handler.rebalance(args.name, args.options)
- except NotAliveException, e:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except NotAliveException as e:
+ msg_type = TMessageType.REPLY
result.e = e
- except InvalidTopologyException, ite:
+ except InvalidTopologyException as ite:
+ msg_type = TMessageType.REPLY
result.ite = ite
- except AuthorizationException, aze:
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("rebalance", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("rebalance", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1407,8 +1474,16 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = setLogConfig_result()
- self._handler.setLogConfig(args.name, args.config)
- oprot.writeMessageBegin("setLogConfig", TMessageType.REPLY, seqid)
+ try:
+ self._handler.setLogConfig(args.name, args.config)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("setLogConfig", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1418,8 +1493,16 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = getLogConfig_result()
- result.success = self._handler.getLogConfig(args.name)
- oprot.writeMessageBegin("getLogConfig", TMessageType.REPLY, seqid)
+ try:
+ result.success = self._handler.getLogConfig(args.name)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("getLogConfig", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1431,11 +1514,20 @@ class Processor(Iface, TProcessor):
result = debug_result()
try:
self._handler.debug(args.name, args.component, args.enable, args.samplingPercentage)
- except NotAliveException, e:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except NotAliveException as e:
+ msg_type = TMessageType.REPLY
result.e = e
- except AuthorizationException, aze:
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("debug", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("debug", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1445,8 +1537,16 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = setWorkerProfiler_result()
- self._handler.setWorkerProfiler(args.id, args.profileRequest)
- oprot.writeMessageBegin("setWorkerProfiler", TMessageType.REPLY, seqid)
+ try:
+ self._handler.setWorkerProfiler(args.id, args.profileRequest)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("setWorkerProfiler", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1456,8 +1556,16 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = getComponentPendingProfileActions_result()
- result.success = self._handler.getComponentPendingProfileActions(args.id, args.component_id, args.action)
- oprot.writeMessageBegin("getComponentPendingProfileActions", TMessageType.REPLY, seqid)
+ try:
+ result.success = self._handler.getComponentPendingProfileActions(args.id, args.component_id, args.action)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("getComponentPendingProfileActions", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1469,13 +1577,23 @@ class Processor(Iface, TProcessor):
result = uploadNewCredentials_result()
try:
self._handler.uploadNewCredentials(args.name, args.creds)
- except NotAliveException, e:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except NotAliveException as e:
+ msg_type = TMessageType.REPLY
result.e = e
- except InvalidTopologyException, ite:
+ except InvalidTopologyException as ite:
+ msg_type = TMessageType.REPLY
result.ite = ite
- except AuthorizationException, aze:
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("uploadNewCredentials", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("uploadNewCredentials", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1487,9 +1605,17 @@ class Processor(Iface, TProcessor):
result = beginFileUpload_result()
try:
result.success = self._handler.beginFileUpload()
- except AuthorizationException, aze:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("beginFileUpload", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("beginFileUpload", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1501,9 +1627,17 @@ class Processor(Iface, TProcessor):
result = uploadChunk_result()
try:
self._handler.uploadChunk(args.location, args.chunk)
- except AuthorizationException, aze:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("uploadChunk", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("uploadChunk", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1515,9 +1649,17 @@ class Processor(Iface, TProcessor):
result = finishFileUpload_result()
try:
self._handler.finishFileUpload(args.location)
- except AuthorizationException, aze:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("finishFileUpload", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("finishFileUpload", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1529,9 +1671,17 @@ class Processor(Iface, TProcessor):
result = beginFileDownload_result()
try:
result.success = self._handler.beginFileDownload(args.file)
- except AuthorizationException, aze:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("beginFileDownload", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("beginFileDownload", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1543,9 +1693,17 @@ class Processor(Iface, TProcessor):
result = downloadChunk_result()
try:
result.success = self._handler.downloadChunk(args.id)
- except AuthorizationException, aze:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("downloadChunk", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("downloadChunk", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1557,9 +1715,17 @@ class Processor(Iface, TProcessor):
result = getNimbusConf_result()
try:
result.success = self._handler.getNimbusConf()
- except AuthorizationException, aze:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("getNimbusConf", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("getNimbusConf", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1571,9 +1737,17 @@ class Processor(Iface, TProcessor):
result = getClusterInfo_result()
try:
result.success = self._handler.getClusterInfo()
- except AuthorizationException, aze:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("getClusterInfo", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("getClusterInfo", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1585,11 +1759,20 @@ class Processor(Iface, TProcessor):
result = getTopologyInfo_result()
try:
result.success = self._handler.getTopologyInfo(args.id)
- except NotAliveException, e:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except NotAliveException as e:
+ msg_type = TMessageType.REPLY
result.e = e
- except AuthorizationException, aze:
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("getTopologyInfo", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("getTopologyInfo", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1601,11 +1784,20 @@ class Processor(Iface, TProcessor):
result = getTopologyInfoWithOpts_result()
try:
result.success = self._handler.getTopologyInfoWithOpts(args.id, args.options)
- except NotAliveException, e:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except NotAliveException as e:
+ msg_type = TMessageType.REPLY
result.e = e
- except AuthorizationException, aze:
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("getTopologyInfoWithOpts", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("getTopologyInfoWithOpts", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1617,11 +1809,20 @@ class Processor(Iface, TProcessor):
result = getTopologyPageInfo_result()
try:
result.success = self._handler.getTopologyPageInfo(args.id, args.window, args.is_include_sys)
- except NotAliveException, e:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except NotAliveException as e:
+ msg_type = TMessageType.REPLY
result.e = e
- except AuthorizationException, aze:
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("getTopologyPageInfo", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("getTopologyPageInfo", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1633,11 +1834,20 @@ class Processor(Iface, TProcessor):
result = getComponentPageInfo_result()
try:
result.success = self._handler.getComponentPageInfo(args.topology_id, args.component_id, args.window, args.is_include_sys)
- except NotAliveException, e:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except NotAliveException as e:
+ msg_type = TMessageType.REPLY
result.e = e
- except AuthorizationException, aze:
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("getComponentPageInfo", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("getComponentPageInfo", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1649,11 +1859,20 @@ class Processor(Iface, TProcessor):
result = getTopologyConf_result()
try:
result.success = self._handler.getTopologyConf(args.id)
- except NotAliveException, e:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except NotAliveException as e:
+ msg_type = TMessageType.REPLY
result.e = e
- except AuthorizationException, aze:
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("getTopologyConf", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("getTopologyConf", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1665,11 +1884,20 @@ class Processor(Iface, TProcessor):
result = getTopology_result()
try:
result.success = self._handler.getTopology(args.id)
- except NotAliveException, e:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except NotAliveException as e:
+ msg_type = TMessageType.REPLY
result.e = e
- except AuthorizationException, aze:
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("getTopology", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("getTopology", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1681,11 +1909,20 @@ class Processor(Iface, TProcessor):
result = getUserTopology_result()
try:
result.success = self._handler.getUserTopology(args.id)
- except NotAliveException, e:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except NotAliveException as e:
+ msg_type = TMessageType.REPLY
result.e = e
- except AuthorizationException, aze:
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("getUserTopology", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("getUserTopology", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -1697,9 +1934,17 @@ class Processor(Iface, TProcessor):
result = getTopologyHistory_result()
try:
result.success = self._handler.getTopologyHistory(args.user)
- except AuthorizationException, aze:
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except AuthorizationException as aze:
+ msg_type = TMessageType.REPLY
result.aze = aze
- oprot.writeMessageBegin("getTopologyHistory", TMessageType.REPLY, seqid)
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("getTopologyHistory", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -3185,12 +3430,12 @@ class debug_args:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.BOOL:
- self.enable = iprot.readBool();
+ self.enable = iprot.readBool()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.DOUBLE:
- self.samplingPercentage = iprot.readDouble();
+ self.samplingPercentage = iprot.readDouble()
else:
iprot.skip(ftype)
else:
@@ -3491,7 +3736,7 @@ class getComponentPendingProfileActions_args:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.I32:
- self.action = iprot.readI32();
+ self.action = iprot.readI32()
else:
iprot.skip(ftype)
else:
@@ -3944,7 +4189,7 @@ class uploadChunk_args:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.chunk = iprot.readString();
+ self.chunk = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -4421,7 +4666,7 @@ class downloadChunk_result:
break
if fid == 0:
if ftype == TType.STRING:
- self.success = iprot.readString();
+ self.success = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 1:
@@ -5092,7 +5337,7 @@ class getTopologyPageInfo_args:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.BOOL:
- self.is_include_sys = iprot.readBool();
+ self.is_include_sys = iprot.readBool()
else:
iprot.skip(ftype)
else:
@@ -5284,7 +5529,7 @@ class getComponentPageInfo_args:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.BOOL:
- self.is_include_sys = iprot.readBool();
+ self.is_include_sys = iprot.readBool()
else:
iprot.skip(ftype)
else:
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/py/storm/constants.py
----------------------------------------------------------------------
diff --git a/storm-core/src/py/storm/constants.py b/storm-core/src/py/storm/constants.py
index 3f0c64a..b403f97 100644
--- a/storm-core/src/py/storm/constants.py
+++ b/storm-core/src/py/storm/constants.py
@@ -17,7 +17,7 @@
# limitations under the License.
#
-# Autogenerated by Thrift Compiler (0.9.2)
+# Autogenerated by Thrift Compiler (0.9.3)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
[6/6] storm git commit: Added STORM-1196 to Changelog
Posted by bo...@apache.org.
Added STORM-1196 to Changelog
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/4eccb151
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/4eccb151
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/4eccb151
Branch: refs/heads/master
Commit: 4eccb151b5f7739271e6fde3059767357ab717ff
Parents: 69abc57
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Thu Nov 12 08:16:24 2015 -0600
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Thu Nov 12 08:16:24 2015 -0600
----------------------------------------------------------------------
CHANGELOG.md | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/4eccb151/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index a132a23..66066fa 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,4 +1,5 @@
## 0.11.0
+ * STORM-1196: Upgrade to thrift 0.9.3
* STORM-1155: Supervisor recurring health checks
* STORM-1189: Maintain wire compatability with 0.10.x versions of storm.
* STORM-1185: replace nimbus.host with nimbus.seeds
[5/6] storm git commit: Merge branch 'STORM-1196' of
https://github.com/knusbaum/incubator-storm into STORM-1196
Posted by bo...@apache.org.
Merge branch 'STORM-1196' of https://github.com/knusbaum/incubator-storm into STORM-1196
STORM-1196: Upgrade to thrift 0.9.3
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/69abc578
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/69abc578
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/69abc578
Branch: refs/heads/master
Commit: 69abc578d9a1c5305e162210f132f62b026e61a0
Parents: 34cda0d c29c2b6
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Thu Nov 12 08:15:57 2015 -0600
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Thu Nov 12 08:15:57 2015 -0600
----------------------------------------------------------------------
pom.xml | 2 +-
storm-core/src/genthrift.sh | 2 +-
.../storm/generated/AlreadyAliveException.java | 11 +-
.../backtype/storm/generated/Assignment.java | 4 +-
.../storm/generated/AuthorizationException.java | 4 +-
.../src/jvm/backtype/storm/generated/Bolt.java | 4 +-
.../storm/generated/BoltAggregateStats.java | 12 +-
.../jvm/backtype/storm/generated/BoltStats.java | 4 +-
.../storm/generated/ClusterSummary.java | 6 +-
.../storm/generated/ClusterWorkerHeartbeat.java | 8 +-
.../storm/generated/CommonAggregateStats.java | 16 +-
.../generated/ComponentAggregateStats.java | 4 +-
.../storm/generated/ComponentCommon.java | 6 +-
.../storm/generated/ComponentObject.java | 2 +-
.../storm/generated/ComponentPageInfo.java | 10 +-
.../backtype/storm/generated/ComponentType.java | 2 +-
.../backtype/storm/generated/Credentials.java | 4 +-
.../storm/generated/DRPCExecutionException.java | 4 +-
.../backtype/storm/generated/DRPCRequest.java | 4 +-
.../backtype/storm/generated/DebugOptions.java | 8 +-
.../storm/generated/DistributedRPC.java | 4 +-
.../generated/DistributedRPCInvocations.java | 4 +-
.../jvm/backtype/storm/generated/ErrorInfo.java | 8 +-
.../storm/generated/ExecutorAggregateStats.java | 4 +-
.../backtype/storm/generated/ExecutorInfo.java | 8 +-
.../storm/generated/ExecutorSpecificStats.java | 2 +-
.../backtype/storm/generated/ExecutorStats.java | 6 +-
.../storm/generated/ExecutorSummary.java | 8 +-
.../storm/generated/GetInfoOptions.java | 4 +-
.../storm/generated/GlobalStreamId.java | 4 +-
.../jvm/backtype/storm/generated/Grouping.java | 2 +-
.../generated/InvalidTopologyException.java | 4 +-
.../backtype/storm/generated/JavaObject.java | 4 +-
.../backtype/storm/generated/JavaObjectArg.java | 2 +-
.../backtype/storm/generated/KillOptions.java | 6 +-
.../storm/generated/LSApprovedWorkers.java | 4 +-
.../generated/LSSupervisorAssignments.java | 4 +-
.../storm/generated/LSSupervisorId.java | 4 +-
.../backtype/storm/generated/LSTopoHistory.java | 6 +-
.../storm/generated/LSTopoHistoryList.java | 4 +-
.../storm/generated/LSWorkerHeartbeat.java | 8 +-
.../storm/generated/LocalAssignment.java | 4 +-
.../storm/generated/LocalStateData.java | 4 +-
.../jvm/backtype/storm/generated/LogConfig.java | 52 +--
.../jvm/backtype/storm/generated/LogLevel.java | 8 +-
.../storm/generated/LogLevelAction.java | 2 +-
.../jvm/backtype/storm/generated/Nimbus.java | 12 +-
.../backtype/storm/generated/NimbusSummary.java | 10 +-
.../jvm/backtype/storm/generated/NodeInfo.java | 4 +-
.../storm/generated/NotAliveException.java | 4 +-
.../backtype/storm/generated/NullStruct.java | 4 +-
.../storm/generated/NumErrorsChoice.java | 2 +-
.../backtype/storm/generated/ProfileAction.java | 2 +-
.../storm/generated/ProfileRequest.java | 6 +-
.../storm/generated/RebalanceOptions.java | 8 +-
.../storm/generated/ShellComponent.java | 4 +-
.../storm/generated/SpecificAggregateStats.java | 2 +-
.../storm/generated/SpoutAggregateStats.java | 6 +-
.../jvm/backtype/storm/generated/SpoutSpec.java | 4 +-
.../backtype/storm/generated/SpoutStats.java | 4 +-
.../storm/generated/StateSpoutSpec.java | 4 +-
.../jvm/backtype/storm/generated/StormBase.java | 8 +-
.../backtype/storm/generated/StormTopology.java | 4 +-
.../backtype/storm/generated/StreamInfo.java | 6 +-
.../backtype/storm/generated/SubmitOptions.java | 4 +-
.../storm/generated/SupervisorInfo.java | 8 +-
.../storm/generated/SupervisorSummary.java | 10 +-
.../storm/generated/ThriftSerializedObject.java | 4 +-
.../storm/generated/TopologyActionOptions.java | 2 +-
.../storm/generated/TopologyHistoryInfo.java | 4 +-
.../backtype/storm/generated/TopologyInfo.java | 20 +-
.../storm/generated/TopologyInitialStatus.java | 2 +-
.../storm/generated/TopologyPageInfo.java | 26 +-
.../backtype/storm/generated/TopologyStats.java | 4 +-
.../storm/generated/TopologyStatus.java | 2 +-
.../storm/generated/TopologySummary.java | 26 +-
.../storm/generated/WorkerResources.java | 10 +-
.../security/auth/SimpleTransportPlugin.java | 2 +-
storm-core/src/py/storm/DistributedRPC-remote | 2 +-
storm-core/src/py/storm/DistributedRPC.py | 20 +-
.../py/storm/DistributedRPCInvocations-remote | 2 +-
.../src/py/storm/DistributedRPCInvocations.py | 41 +-
storm-core/src/py/storm/Nimbus-remote | 2 +-
storm-core/src/py/storm/Nimbus.py | 443 ++++++++++++++-----
storm-core/src/py/storm/constants.py | 2 +-
storm-core/src/py/storm/ttypes.py | 248 +++++------
86 files changed, 773 insertions(+), 492 deletions(-)
----------------------------------------------------------------------
[3/6] storm git commit: Upgrading to thrift 0.9.3
Posted by bo...@apache.org.
Upgrading to thrift 0.9.3
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/73650789
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/73650789
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/73650789
Branch: refs/heads/master
Commit: 73650789729876f016810a8caf59bc9ef85601e1
Parents: 2b6884b
Author: Kyle Nusbaum <Ky...@gmail.com>
Authored: Tue Nov 10 14:02:03 2015 -0600
Committer: Kyle Nusbaum <Ky...@gmail.com>
Committed: Tue Nov 10 14:02:03 2015 -0600
----------------------------------------------------------------------
pom.xml | 2 +-
storm-core/src/genthrift.sh | 2 +-
.../storm/generated/AlreadyAliveException.java | 11 +-
.../backtype/storm/generated/Assignment.java | 4 +-
.../storm/generated/AuthorizationException.java | 4 +-
.../src/jvm/backtype/storm/generated/Bolt.java | 4 +-
.../storm/generated/BoltAggregateStats.java | 12 +-
.../jvm/backtype/storm/generated/BoltStats.java | 4 +-
.../storm/generated/ClusterSummary.java | 6 +-
.../storm/generated/ClusterWorkerHeartbeat.java | 8 +-
.../storm/generated/CommonAggregateStats.java | 16 +-
.../generated/ComponentAggregateStats.java | 4 +-
.../storm/generated/ComponentCommon.java | 6 +-
.../storm/generated/ComponentObject.java | 2 +-
.../storm/generated/ComponentPageInfo.java | 10 +-
.../backtype/storm/generated/ComponentType.java | 2 +-
.../backtype/storm/generated/Credentials.java | 4 +-
.../storm/generated/DRPCExecutionException.java | 4 +-
.../backtype/storm/generated/DRPCRequest.java | 4 +-
.../backtype/storm/generated/DebugOptions.java | 8 +-
.../storm/generated/DistributedRPC.java | 4 +-
.../generated/DistributedRPCInvocations.java | 4 +-
.../jvm/backtype/storm/generated/ErrorInfo.java | 8 +-
.../storm/generated/ExecutorAggregateStats.java | 4 +-
.../backtype/storm/generated/ExecutorInfo.java | 8 +-
.../storm/generated/ExecutorSpecificStats.java | 2 +-
.../backtype/storm/generated/ExecutorStats.java | 6 +-
.../storm/generated/ExecutorSummary.java | 8 +-
.../storm/generated/GetInfoOptions.java | 4 +-
.../storm/generated/GlobalStreamId.java | 4 +-
.../jvm/backtype/storm/generated/Grouping.java | 2 +-
.../generated/InvalidTopologyException.java | 4 +-
.../backtype/storm/generated/JavaObject.java | 4 +-
.../backtype/storm/generated/JavaObjectArg.java | 2 +-
.../backtype/storm/generated/KillOptions.java | 6 +-
.../storm/generated/LSApprovedWorkers.java | 4 +-
.../generated/LSSupervisorAssignments.java | 4 +-
.../storm/generated/LSSupervisorId.java | 4 +-
.../backtype/storm/generated/LSTopoHistory.java | 6 +-
.../storm/generated/LSTopoHistoryList.java | 4 +-
.../storm/generated/LSWorkerHeartbeat.java | 8 +-
.../storm/generated/LocalAssignment.java | 4 +-
.../storm/generated/LocalStateData.java | 4 +-
.../jvm/backtype/storm/generated/LogConfig.java | 52 +--
.../jvm/backtype/storm/generated/LogLevel.java | 8 +-
.../storm/generated/LogLevelAction.java | 2 +-
.../jvm/backtype/storm/generated/Nimbus.java | 12 +-
.../backtype/storm/generated/NimbusSummary.java | 10 +-
.../jvm/backtype/storm/generated/NodeInfo.java | 4 +-
.../storm/generated/NotAliveException.java | 4 +-
.../backtype/storm/generated/NullStruct.java | 4 +-
.../storm/generated/NumErrorsChoice.java | 2 +-
.../backtype/storm/generated/ProfileAction.java | 2 +-
.../storm/generated/ProfileRequest.java | 6 +-
.../storm/generated/RebalanceOptions.java | 8 +-
.../storm/generated/ShellComponent.java | 4 +-
.../storm/generated/SpecificAggregateStats.java | 2 +-
.../storm/generated/SpoutAggregateStats.java | 6 +-
.../jvm/backtype/storm/generated/SpoutSpec.java | 4 +-
.../backtype/storm/generated/SpoutStats.java | 4 +-
.../storm/generated/StateSpoutSpec.java | 4 +-
.../jvm/backtype/storm/generated/StormBase.java | 8 +-
.../backtype/storm/generated/StormTopology.java | 4 +-
.../backtype/storm/generated/StreamInfo.java | 6 +-
.../backtype/storm/generated/SubmitOptions.java | 4 +-
.../storm/generated/SupervisorInfo.java | 8 +-
.../storm/generated/SupervisorSummary.java | 10 +-
.../storm/generated/ThriftSerializedObject.java | 4 +-
.../storm/generated/TopologyActionOptions.java | 2 +-
.../storm/generated/TopologyHistoryInfo.java | 4 +-
.../backtype/storm/generated/TopologyInfo.java | 20 +-
.../storm/generated/TopologyInitialStatus.java | 2 +-
.../storm/generated/TopologyPageInfo.java | 26 +-
.../backtype/storm/generated/TopologyStats.java | 4 +-
.../storm/generated/TopologyStatus.java | 2 +-
.../storm/generated/TopologySummary.java | 26 +-
.../storm/generated/WorkerResources.java | 10 +-
.../security/auth/SimpleTransportPlugin.java | 2 +-
storm-core/src/py/storm/DistributedRPC-remote | 2 +-
storm-core/src/py/storm/DistributedRPC.py | 20 +-
.../py/storm/DistributedRPCInvocations-remote | 2 +-
.../src/py/storm/DistributedRPCInvocations.py | 41 +-
storm-core/src/py/storm/Nimbus-remote | 2 +-
storm-core/src/py/storm/Nimbus.py | 443 ++++++++++++++-----
storm-core/src/py/storm/constants.py | 2 +-
storm-core/src/py/storm/ttypes.py | 248 +++++------
86 files changed, 773 insertions(+), 492 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index b90dd79..dd2818b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -212,7 +212,7 @@
<servlet.version>2.5</servlet.version>
<joda-time.version>2.3</joda-time.version>
<jackson.version>2.3.1</jackson.version>
- <thrift.version>0.9.2</thrift.version>
+ <thrift.version>0.9.3</thrift.version>
<junit.version>4.11</junit.version>
<metrics-clojure.version>2.5.1</metrics-clojure.version>
<hdrhistogram.version>2.1.7</hdrhistogram.version>
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/genthrift.sh
----------------------------------------------------------------------
diff --git a/storm-core/src/genthrift.sh b/storm-core/src/genthrift.sh
old mode 100644
new mode 100755
index 7e90576..54cd10a
--- a/storm-core/src/genthrift.sh
+++ b/storm-core/src/genthrift.sh
@@ -17,7 +17,7 @@
rm -rf gen-javabean gen-py py
rm -rf jvm/backtype/storm/generated
-thrift --gen java:beans,hashcode,nocamel --gen py:utf8strings storm.thrift
+thrift --gen java:beans,hashcode,nocamel,generated_annotations=undated --gen py:utf8strings storm.thrift
for file in gen-javabean/backtype/storm/generated/* ; do
cat java_license_header.txt ${file} > ${file}.tmp
mv -f ${file}.tmp ${file}
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/AlreadyAliveException.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/AlreadyAliveException.java b/storm-core/src/jvm/backtype/storm/generated/AlreadyAliveException.java
index adc71a2..eecf044 100644
--- a/storm-core/src/jvm/backtype/storm/generated/AlreadyAliveException.java
+++ b/storm-core/src/jvm/backtype/storm/generated/AlreadyAliveException.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class AlreadyAliveException extends TException implements org.apache.thrift.TBase<AlreadyAliveException, AlreadyAliveException._Fields>, java.io.Serializable, Cloneable, Comparable<AlreadyAliveException> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AlreadyAliveException");
@@ -221,10 +221,11 @@ public class AlreadyAliveException extends TException implements org.apache.thri
@Override
public boolean equals(Object that) {
- if (that == null) {
+ if (that == null)
return false;
- }
- return (that instanceof AlreadyAliveException) ? this.equals((AlreadyAliveException)that) : false;
+ if (that instanceof AlreadyAliveException)
+ return this.equals((AlreadyAliveException)that);
+ return false;
}
public boolean equals(AlreadyAliveException that) {
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/Assignment.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/Assignment.java b/storm-core/src/jvm/backtype/storm/generated/Assignment.java
index dbc1cc9..25874a4 100644
--- a/storm-core/src/jvm/backtype/storm/generated/Assignment.java
+++ b/storm-core/src/jvm/backtype/storm/generated/Assignment.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class Assignment implements org.apache.thrift.TBase<Assignment, Assignment._Fields>, java.io.Serializable, Cloneable, Comparable<Assignment> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Assignment");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/AuthorizationException.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/AuthorizationException.java b/storm-core/src/jvm/backtype/storm/generated/AuthorizationException.java
index 69fff12..c4bf053 100644
--- a/storm-core/src/jvm/backtype/storm/generated/AuthorizationException.java
+++ b/storm-core/src/jvm/backtype/storm/generated/AuthorizationException.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class AuthorizationException extends TException implements org.apache.thrift.TBase<AuthorizationException, AuthorizationException._Fields>, java.io.Serializable, Cloneable, Comparable<AuthorizationException> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AuthorizationException");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/Bolt.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/Bolt.java b/storm-core/src/jvm/backtype/storm/generated/Bolt.java
index 9ea4bef..df1a007 100644
--- a/storm-core/src/jvm/backtype/storm/generated/Bolt.java
+++ b/storm-core/src/jvm/backtype/storm/generated/Bolt.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class Bolt implements org.apache.thrift.TBase<Bolt, Bolt._Fields>, java.io.Serializable, Cloneable, Comparable<Bolt> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Bolt");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/BoltAggregateStats.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/BoltAggregateStats.java b/storm-core/src/jvm/backtype/storm/generated/BoltAggregateStats.java
index 940e0b9..061f3fb 100644
--- a/storm-core/src/jvm/backtype/storm/generated/BoltAggregateStats.java
+++ b/storm-core/src/jvm/backtype/storm/generated/BoltAggregateStats.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregateStats, BoltAggregateStats._Fields>, java.io.Serializable, Cloneable, Comparable<BoltAggregateStats> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("BoltAggregateStats");
@@ -318,16 +318,16 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate
public Object getFieldValue(_Fields field) {
switch (field) {
case EXECUTE_LATENCY_MS:
- return Double.valueOf(get_execute_latency_ms());
+ return get_execute_latency_ms();
case PROCESS_LATENCY_MS:
- return Double.valueOf(get_process_latency_ms());
+ return get_process_latency_ms();
case EXECUTED:
- return Long.valueOf(get_executed());
+ return get_executed();
case CAPACITY:
- return Double.valueOf(get_capacity());
+ return get_capacity();
}
throw new IllegalStateException();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/BoltStats.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/BoltStats.java b/storm-core/src/jvm/backtype/storm/generated/BoltStats.java
index c3ffc9f..6cef48a 100644
--- a/storm-core/src/jvm/backtype/storm/generated/BoltStats.java
+++ b/storm-core/src/jvm/backtype/storm/generated/BoltStats.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._Fields>, java.io.Serializable, Cloneable, Comparable<BoltStats> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("BoltStats");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/ClusterSummary.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ClusterSummary.java b/storm-core/src/jvm/backtype/storm/generated/ClusterSummary.java
index c8c7c28..5292b78 100644
--- a/storm-core/src/jvm/backtype/storm/generated/ClusterSummary.java
+++ b/storm-core/src/jvm/backtype/storm/generated/ClusterSummary.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-11-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, ClusterSummary._Fields>, java.io.Serializable, Cloneable, Comparable<ClusterSummary> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ClusterSummary");
@@ -397,7 +397,7 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C
return get_supervisors();
case NIMBUS_UPTIME_SECS:
- return Integer.valueOf(get_nimbus_uptime_secs());
+ return get_nimbus_uptime_secs();
case TOPOLOGIES:
return get_topologies();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/ClusterWorkerHeartbeat.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ClusterWorkerHeartbeat.java b/storm-core/src/jvm/backtype/storm/generated/ClusterWorkerHeartbeat.java
index 6c84d4c..0ac0352 100644
--- a/storm-core/src/jvm/backtype/storm/generated/ClusterWorkerHeartbeat.java
+++ b/storm-core/src/jvm/backtype/storm/generated/ClusterWorkerHeartbeat.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class ClusterWorkerHeartbeat implements org.apache.thrift.TBase<ClusterWorkerHeartbeat, ClusterWorkerHeartbeat._Fields>, java.io.Serializable, Cloneable, Comparable<ClusterWorkerHeartbeat> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ClusterWorkerHeartbeat");
@@ -365,10 +365,10 @@ public class ClusterWorkerHeartbeat implements org.apache.thrift.TBase<ClusterWo
return get_executor_stats();
case TIME_SECS:
- return Integer.valueOf(get_time_secs());
+ return get_time_secs();
case UPTIME_SECS:
- return Integer.valueOf(get_uptime_secs());
+ return get_uptime_secs();
}
throw new IllegalStateException();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/CommonAggregateStats.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/CommonAggregateStats.java b/storm-core/src/jvm/backtype/storm/generated/CommonAggregateStats.java
index 108f74f..f1ff590 100644
--- a/storm-core/src/jvm/backtype/storm/generated/CommonAggregateStats.java
+++ b/storm-core/src/jvm/backtype/storm/generated/CommonAggregateStats.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class CommonAggregateStats implements org.apache.thrift.TBase<CommonAggregateStats, CommonAggregateStats._Fields>, java.io.Serializable, Cloneable, Comparable<CommonAggregateStats> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("CommonAggregateStats");
@@ -400,22 +400,22 @@ public class CommonAggregateStats implements org.apache.thrift.TBase<CommonAggre
public Object getFieldValue(_Fields field) {
switch (field) {
case NUM_EXECUTORS:
- return Integer.valueOf(get_num_executors());
+ return get_num_executors();
case NUM_TASKS:
- return Integer.valueOf(get_num_tasks());
+ return get_num_tasks();
case EMITTED:
- return Long.valueOf(get_emitted());
+ return get_emitted();
case TRANSFERRED:
- return Long.valueOf(get_transferred());
+ return get_transferred();
case ACKED:
- return Long.valueOf(get_acked());
+ return get_acked();
case FAILED:
- return Long.valueOf(get_failed());
+ return get_failed();
}
throw new IllegalStateException();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/ComponentAggregateStats.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ComponentAggregateStats.java b/storm-core/src/jvm/backtype/storm/generated/ComponentAggregateStats.java
index 8fe77b3..eea060f 100644
--- a/storm-core/src/jvm/backtype/storm/generated/ComponentAggregateStats.java
+++ b/storm-core/src/jvm/backtype/storm/generated/ComponentAggregateStats.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class ComponentAggregateStats implements org.apache.thrift.TBase<ComponentAggregateStats, ComponentAggregateStats._Fields>, java.io.Serializable, Cloneable, Comparable<ComponentAggregateStats> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ComponentAggregateStats");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/ComponentCommon.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ComponentCommon.java b/storm-core/src/jvm/backtype/storm/generated/ComponentCommon.java
index c69edf2..9950756 100644
--- a/storm-core/src/jvm/backtype/storm/generated/ComponentCommon.java
+++ b/storm-core/src/jvm/backtype/storm/generated/ComponentCommon.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class ComponentCommon implements org.apache.thrift.TBase<ComponentCommon, ComponentCommon._Fields>, java.io.Serializable, Cloneable, Comparable<ComponentCommon> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ComponentCommon");
@@ -386,7 +386,7 @@ public class ComponentCommon implements org.apache.thrift.TBase<ComponentCommon,
return get_streams();
case PARALLELISM_HINT:
- return Integer.valueOf(get_parallelism_hint());
+ return get_parallelism_hint();
case JSON_CONF:
return get_json_conf();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/ComponentObject.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ComponentObject.java b/storm-core/src/jvm/backtype/storm/generated/ComponentObject.java
index 575069f..722e7db 100644
--- a/storm-core/src/jvm/backtype/storm/generated/ComponentObject.java
+++ b/storm-core/src/jvm/backtype/storm/generated/ComponentObject.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/ComponentPageInfo.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ComponentPageInfo.java b/storm-core/src/jvm/backtype/storm/generated/ComponentPageInfo.java
index c8fcf7b..e2a538b 100644
--- a/storm-core/src/jvm/backtype/storm/generated/ComponentPageInfo.java
+++ b/storm-core/src/jvm/backtype/storm/generated/ComponentPageInfo.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class ComponentPageInfo implements org.apache.thrift.TBase<ComponentPageInfo, ComponentPageInfo._Fields>, java.io.Serializable, Cloneable, Comparable<ComponentPageInfo> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ComponentPageInfo");
@@ -929,10 +929,10 @@ public class ComponentPageInfo implements org.apache.thrift.TBase<ComponentPageI
return get_topology_name();
case NUM_EXECUTORS:
- return Integer.valueOf(get_num_executors());
+ return get_num_executors();
case NUM_TASKS:
- return Integer.valueOf(get_num_tasks());
+ return get_num_tasks();
case WINDOW_TO_STATS:
return get_window_to_stats();
@@ -953,7 +953,7 @@ public class ComponentPageInfo implements org.apache.thrift.TBase<ComponentPageI
return get_eventlog_host();
case EVENTLOG_PORT:
- return Integer.valueOf(get_eventlog_port());
+ return get_eventlog_port();
case DEBUG_OPTIONS:
return get_debug_options();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/ComponentType.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ComponentType.java b/storm-core/src/jvm/backtype/storm/generated/ComponentType.java
index 9efdba4..086feb7 100644
--- a/storm-core/src/jvm/backtype/storm/generated/ComponentType.java
+++ b/storm-core/src/jvm/backtype/storm/generated/ComponentType.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/Credentials.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/Credentials.java b/storm-core/src/jvm/backtype/storm/generated/Credentials.java
index 71a764f..1f8f00c 100644
--- a/storm-core/src/jvm/backtype/storm/generated/Credentials.java
+++ b/storm-core/src/jvm/backtype/storm/generated/Credentials.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class Credentials implements org.apache.thrift.TBase<Credentials, Credentials._Fields>, java.io.Serializable, Cloneable, Comparable<Credentials> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Credentials");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/DRPCExecutionException.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/DRPCExecutionException.java b/storm-core/src/jvm/backtype/storm/generated/DRPCExecutionException.java
index 1471537..7f10776 100644
--- a/storm-core/src/jvm/backtype/storm/generated/DRPCExecutionException.java
+++ b/storm-core/src/jvm/backtype/storm/generated/DRPCExecutionException.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class DRPCExecutionException extends TException implements org.apache.thrift.TBase<DRPCExecutionException, DRPCExecutionException._Fields>, java.io.Serializable, Cloneable, Comparable<DRPCExecutionException> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("DRPCExecutionException");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/DRPCRequest.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/DRPCRequest.java b/storm-core/src/jvm/backtype/storm/generated/DRPCRequest.java
index 4648c36..569df6e 100644
--- a/storm-core/src/jvm/backtype/storm/generated/DRPCRequest.java
+++ b/storm-core/src/jvm/backtype/storm/generated/DRPCRequest.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class DRPCRequest implements org.apache.thrift.TBase<DRPCRequest, DRPCRequest._Fields>, java.io.Serializable, Cloneable, Comparable<DRPCRequest> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("DRPCRequest");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/DebugOptions.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/DebugOptions.java b/storm-core/src/jvm/backtype/storm/generated/DebugOptions.java
index da7a45a..f53cf98 100644
--- a/storm-core/src/jvm/backtype/storm/generated/DebugOptions.java
+++ b/storm-core/src/jvm/backtype/storm/generated/DebugOptions.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class DebugOptions implements org.apache.thrift.TBase<DebugOptions, DebugOptions._Fields>, java.io.Serializable, Cloneable, Comparable<DebugOptions> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("DebugOptions");
@@ -236,10 +236,10 @@ public class DebugOptions implements org.apache.thrift.TBase<DebugOptions, Debug
public Object getFieldValue(_Fields field) {
switch (field) {
case ENABLE:
- return Boolean.valueOf(is_enable());
+ return is_enable();
case SAMPLINGPCT:
- return Double.valueOf(get_samplingpct());
+ return get_samplingpct();
}
throw new IllegalStateException();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/DistributedRPC.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/DistributedRPC.java b/storm-core/src/jvm/backtype/storm/generated/DistributedRPC.java
index 475746b..1a42417 100644
--- a/storm-core/src/jvm/backtype/storm/generated/DistributedRPC.java
+++ b/storm-core/src/jvm/backtype/storm/generated/DistributedRPC.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class DistributedRPC {
public interface Iface {
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/DistributedRPCInvocations.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/DistributedRPCInvocations.java b/storm-core/src/jvm/backtype/storm/generated/DistributedRPCInvocations.java
index d0c7f64..48271ad 100644
--- a/storm-core/src/jvm/backtype/storm/generated/DistributedRPCInvocations.java
+++ b/storm-core/src/jvm/backtype/storm/generated/DistributedRPCInvocations.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class DistributedRPCInvocations {
public interface Iface {
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/ErrorInfo.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ErrorInfo.java b/storm-core/src/jvm/backtype/storm/generated/ErrorInfo.java
index 515a436..83f10e6 100644
--- a/storm-core/src/jvm/backtype/storm/generated/ErrorInfo.java
+++ b/storm-core/src/jvm/backtype/storm/generated/ErrorInfo.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class ErrorInfo implements org.apache.thrift.TBase<ErrorInfo, ErrorInfo._Fields>, java.io.Serializable, Cloneable, Comparable<ErrorInfo> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ErrorInfo");
@@ -333,13 +333,13 @@ public class ErrorInfo implements org.apache.thrift.TBase<ErrorInfo, ErrorInfo._
return get_error();
case ERROR_TIME_SECS:
- return Integer.valueOf(get_error_time_secs());
+ return get_error_time_secs();
case HOST:
return get_host();
case PORT:
- return Integer.valueOf(get_port());
+ return get_port();
}
throw new IllegalStateException();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/ExecutorAggregateStats.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ExecutorAggregateStats.java b/storm-core/src/jvm/backtype/storm/generated/ExecutorAggregateStats.java
index 4993cc5..e9d82b4 100644
--- a/storm-core/src/jvm/backtype/storm/generated/ExecutorAggregateStats.java
+++ b/storm-core/src/jvm/backtype/storm/generated/ExecutorAggregateStats.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class ExecutorAggregateStats implements org.apache.thrift.TBase<ExecutorAggregateStats, ExecutorAggregateStats._Fields>, java.io.Serializable, Cloneable, Comparable<ExecutorAggregateStats> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ExecutorAggregateStats");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/ExecutorInfo.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ExecutorInfo.java b/storm-core/src/jvm/backtype/storm/generated/ExecutorInfo.java
index 3f27a51..3613de7 100644
--- a/storm-core/src/jvm/backtype/storm/generated/ExecutorInfo.java
+++ b/storm-core/src/jvm/backtype/storm/generated/ExecutorInfo.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class ExecutorInfo implements org.apache.thrift.TBase<ExecutorInfo, ExecutorInfo._Fields>, java.io.Serializable, Cloneable, Comparable<ExecutorInfo> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ExecutorInfo");
@@ -246,10 +246,10 @@ public class ExecutorInfo implements org.apache.thrift.TBase<ExecutorInfo, Execu
public Object getFieldValue(_Fields field) {
switch (field) {
case TASK_START:
- return Integer.valueOf(get_task_start());
+ return get_task_start();
case TASK_END:
- return Integer.valueOf(get_task_end());
+ return get_task_end();
}
throw new IllegalStateException();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/ExecutorSpecificStats.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ExecutorSpecificStats.java b/storm-core/src/jvm/backtype/storm/generated/ExecutorSpecificStats.java
index 06b741c..09fa80a 100644
--- a/storm-core/src/jvm/backtype/storm/generated/ExecutorSpecificStats.java
+++ b/storm-core/src/jvm/backtype/storm/generated/ExecutorSpecificStats.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/ExecutorStats.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ExecutorStats.java b/storm-core/src/jvm/backtype/storm/generated/ExecutorStats.java
index 4783c82..ec6cad4 100644
--- a/storm-core/src/jvm/backtype/storm/generated/ExecutorStats.java
+++ b/storm-core/src/jvm/backtype/storm/generated/ExecutorStats.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class ExecutorStats implements org.apache.thrift.TBase<ExecutorStats, ExecutorStats._Fields>, java.io.Serializable, Cloneable, Comparable<ExecutorStats> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ExecutorStats");
@@ -397,7 +397,7 @@ public class ExecutorStats implements org.apache.thrift.TBase<ExecutorStats, Exe
return get_specific();
case RATE:
- return Double.valueOf(get_rate());
+ return get_rate();
}
throw new IllegalStateException();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/ExecutorSummary.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ExecutorSummary.java b/storm-core/src/jvm/backtype/storm/generated/ExecutorSummary.java
index 4f70a32..84de5d7 100644
--- a/storm-core/src/jvm/backtype/storm/generated/ExecutorSummary.java
+++ b/storm-core/src/jvm/backtype/storm/generated/ExecutorSummary.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class ExecutorSummary implements org.apache.thrift.TBase<ExecutorSummary, ExecutorSummary._Fields>, java.io.Serializable, Cloneable, Comparable<ExecutorSummary> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ExecutorSummary");
@@ -430,10 +430,10 @@ public class ExecutorSummary implements org.apache.thrift.TBase<ExecutorSummary,
return get_host();
case PORT:
- return Integer.valueOf(get_port());
+ return get_port();
case UPTIME_SECS:
- return Integer.valueOf(get_uptime_secs());
+ return get_uptime_secs();
case STATS:
return get_stats();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/GetInfoOptions.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/GetInfoOptions.java b/storm-core/src/jvm/backtype/storm/generated/GetInfoOptions.java
index 90c811f..dac49f1 100644
--- a/storm-core/src/jvm/backtype/storm/generated/GetInfoOptions.java
+++ b/storm-core/src/jvm/backtype/storm/generated/GetInfoOptions.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class GetInfoOptions implements org.apache.thrift.TBase<GetInfoOptions, GetInfoOptions._Fields>, java.io.Serializable, Cloneable, Comparable<GetInfoOptions> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GetInfoOptions");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/GlobalStreamId.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/GlobalStreamId.java b/storm-core/src/jvm/backtype/storm/generated/GlobalStreamId.java
index 8a0e1c7..71a678f 100644
--- a/storm-core/src/jvm/backtype/storm/generated/GlobalStreamId.java
+++ b/storm-core/src/jvm/backtype/storm/generated/GlobalStreamId.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class GlobalStreamId implements org.apache.thrift.TBase<GlobalStreamId, GlobalStreamId._Fields>, java.io.Serializable, Cloneable, Comparable<GlobalStreamId> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GlobalStreamId");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/Grouping.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/Grouping.java b/storm-core/src/jvm/backtype/storm/generated/Grouping.java
index 3994499..5b29bc6 100644
--- a/storm-core/src/jvm/backtype/storm/generated/Grouping.java
+++ b/storm-core/src/jvm/backtype/storm/generated/Grouping.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/InvalidTopologyException.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/InvalidTopologyException.java b/storm-core/src/jvm/backtype/storm/generated/InvalidTopologyException.java
index 003dae7..934a0bf 100644
--- a/storm-core/src/jvm/backtype/storm/generated/InvalidTopologyException.java
+++ b/storm-core/src/jvm/backtype/storm/generated/InvalidTopologyException.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class InvalidTopologyException extends TException implements org.apache.thrift.TBase<InvalidTopologyException, InvalidTopologyException._Fields>, java.io.Serializable, Cloneable, Comparable<InvalidTopologyException> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("InvalidTopologyException");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/JavaObject.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/JavaObject.java b/storm-core/src/jvm/backtype/storm/generated/JavaObject.java
index 15d8fd7..ddde594 100644
--- a/storm-core/src/jvm/backtype/storm/generated/JavaObject.java
+++ b/storm-core/src/jvm/backtype/storm/generated/JavaObject.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class JavaObject implements org.apache.thrift.TBase<JavaObject, JavaObject._Fields>, java.io.Serializable, Cloneable, Comparable<JavaObject> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("JavaObject");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/JavaObjectArg.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/JavaObjectArg.java b/storm-core/src/jvm/backtype/storm/generated/JavaObjectArg.java
index e69bd34..47d0eaf 100644
--- a/storm-core/src/jvm/backtype/storm/generated/JavaObjectArg.java
+++ b/storm-core/src/jvm/backtype/storm/generated/JavaObjectArg.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/KillOptions.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/KillOptions.java b/storm-core/src/jvm/backtype/storm/generated/KillOptions.java
index bebfbb1..f386ec1 100644
--- a/storm-core/src/jvm/backtype/storm/generated/KillOptions.java
+++ b/storm-core/src/jvm/backtype/storm/generated/KillOptions.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class KillOptions implements org.apache.thrift.TBase<KillOptions, KillOptions._Fields>, java.io.Serializable, Cloneable, Comparable<KillOptions> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("KillOptions");
@@ -195,7 +195,7 @@ public class KillOptions implements org.apache.thrift.TBase<KillOptions, KillOpt
public Object getFieldValue(_Fields field) {
switch (field) {
case WAIT_SECS:
- return Integer.valueOf(get_wait_secs());
+ return get_wait_secs();
}
throw new IllegalStateException();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/LSApprovedWorkers.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/LSApprovedWorkers.java b/storm-core/src/jvm/backtype/storm/generated/LSApprovedWorkers.java
index 75da228..bf801bc 100644
--- a/storm-core/src/jvm/backtype/storm/generated/LSApprovedWorkers.java
+++ b/storm-core/src/jvm/backtype/storm/generated/LSApprovedWorkers.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class LSApprovedWorkers implements org.apache.thrift.TBase<LSApprovedWorkers, LSApprovedWorkers._Fields>, java.io.Serializable, Cloneable, Comparable<LSApprovedWorkers> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("LSApprovedWorkers");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/LSSupervisorAssignments.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/LSSupervisorAssignments.java b/storm-core/src/jvm/backtype/storm/generated/LSSupervisorAssignments.java
index 7eb3628..1ee0e6c 100644
--- a/storm-core/src/jvm/backtype/storm/generated/LSSupervisorAssignments.java
+++ b/storm-core/src/jvm/backtype/storm/generated/LSSupervisorAssignments.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class LSSupervisorAssignments implements org.apache.thrift.TBase<LSSupervisorAssignments, LSSupervisorAssignments._Fields>, java.io.Serializable, Cloneable, Comparable<LSSupervisorAssignments> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("LSSupervisorAssignments");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/LSSupervisorId.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/LSSupervisorId.java b/storm-core/src/jvm/backtype/storm/generated/LSSupervisorId.java
index 8b0241a..8be48fa 100644
--- a/storm-core/src/jvm/backtype/storm/generated/LSSupervisorId.java
+++ b/storm-core/src/jvm/backtype/storm/generated/LSSupervisorId.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class LSSupervisorId implements org.apache.thrift.TBase<LSSupervisorId, LSSupervisorId._Fields>, java.io.Serializable, Cloneable, Comparable<LSSupervisorId> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("LSSupervisorId");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/LSTopoHistory.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/LSTopoHistory.java b/storm-core/src/jvm/backtype/storm/generated/LSTopoHistory.java
index 75fde1e..cb890b4 100644
--- a/storm-core/src/jvm/backtype/storm/generated/LSTopoHistory.java
+++ b/storm-core/src/jvm/backtype/storm/generated/LSTopoHistory.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-11-4")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class LSTopoHistory implements org.apache.thrift.TBase<LSTopoHistory, LSTopoHistory._Fields>, java.io.Serializable, Cloneable, Comparable<LSTopoHistory> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("LSTopoHistory");
@@ -371,7 +371,7 @@ public class LSTopoHistory implements org.apache.thrift.TBase<LSTopoHistory, LST
return get_topology_id();
case TIME_STAMP:
- return Long.valueOf(get_time_stamp());
+ return get_time_stamp();
case USERS:
return get_users();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/LSTopoHistoryList.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/LSTopoHistoryList.java b/storm-core/src/jvm/backtype/storm/generated/LSTopoHistoryList.java
index 0483285..ffb1d9e 100644
--- a/storm-core/src/jvm/backtype/storm/generated/LSTopoHistoryList.java
+++ b/storm-core/src/jvm/backtype/storm/generated/LSTopoHistoryList.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-11-4")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class LSTopoHistoryList implements org.apache.thrift.TBase<LSTopoHistoryList, LSTopoHistoryList._Fields>, java.io.Serializable, Cloneable, Comparable<LSTopoHistoryList> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("LSTopoHistoryList");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/LSWorkerHeartbeat.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/LSWorkerHeartbeat.java b/storm-core/src/jvm/backtype/storm/generated/LSWorkerHeartbeat.java
index fc37eb1..0f123f1 100644
--- a/storm-core/src/jvm/backtype/storm/generated/LSWorkerHeartbeat.java
+++ b/storm-core/src/jvm/backtype/storm/generated/LSWorkerHeartbeat.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class LSWorkerHeartbeat implements org.apache.thrift.TBase<LSWorkerHeartbeat, LSWorkerHeartbeat._Fields>, java.io.Serializable, Cloneable, Comparable<LSWorkerHeartbeat> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("LSWorkerHeartbeat");
@@ -354,7 +354,7 @@ public class LSWorkerHeartbeat implements org.apache.thrift.TBase<LSWorkerHeartb
public Object getFieldValue(_Fields field) {
switch (field) {
case TIME_SECS:
- return Integer.valueOf(get_time_secs());
+ return get_time_secs();
case TOPOLOGY_ID:
return get_topology_id();
@@ -363,7 +363,7 @@ public class LSWorkerHeartbeat implements org.apache.thrift.TBase<LSWorkerHeartb
return get_executors();
case PORT:
- return Integer.valueOf(get_port());
+ return get_port();
}
throw new IllegalStateException();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/LocalAssignment.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/LocalAssignment.java b/storm-core/src/jvm/backtype/storm/generated/LocalAssignment.java
index 1e9f05c..abfb4a4 100644
--- a/storm-core/src/jvm/backtype/storm/generated/LocalAssignment.java
+++ b/storm-core/src/jvm/backtype/storm/generated/LocalAssignment.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class LocalAssignment implements org.apache.thrift.TBase<LocalAssignment, LocalAssignment._Fields>, java.io.Serializable, Cloneable, Comparable<LocalAssignment> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("LocalAssignment");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/LocalStateData.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/LocalStateData.java b/storm-core/src/jvm/backtype/storm/generated/LocalStateData.java
index e821149..384cab5 100644
--- a/storm-core/src/jvm/backtype/storm/generated/LocalStateData.java
+++ b/storm-core/src/jvm/backtype/storm/generated/LocalStateData.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class LocalStateData implements org.apache.thrift.TBase<LocalStateData, LocalStateData._Fields>, java.io.Serializable, Cloneable, Comparable<LocalStateData> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("LocalStateData");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/LogConfig.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/LogConfig.java b/storm-core/src/jvm/backtype/storm/generated/LogConfig.java
index 6d537f8..b74b17f 100644
--- a/storm-core/src/jvm/backtype/storm/generated/LogConfig.java
+++ b/storm-core/src/jvm/backtype/storm/generated/LogConfig.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class LogConfig implements org.apache.thrift.TBase<LogConfig, LogConfig._Fields>, java.io.Serializable, Cloneable, Comparable<LogConfig> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("LogConfig");
@@ -368,16 +368,16 @@ public class LogConfig implements org.apache.thrift.TBase<LogConfig, LogConfig._
case 2: // NAMED_LOGGER_LEVEL
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map656 = iprot.readMapBegin();
- struct.named_logger_level = new HashMap<String,LogLevel>(2*_map656.size);
- String _key657;
- LogLevel _val658;
- for (int _i659 = 0; _i659 < _map656.size; ++_i659)
+ org.apache.thrift.protocol.TMap _map680 = iprot.readMapBegin();
+ struct.named_logger_level = new HashMap<String,LogLevel>(2*_map680.size);
+ String _key681;
+ LogLevel _val682;
+ for (int _i683 = 0; _i683 < _map680.size; ++_i683)
{
- _key657 = iprot.readString();
- _val658 = new LogLevel();
- _val658.read(iprot);
- struct.named_logger_level.put(_key657, _val658);
+ _key681 = iprot.readString();
+ _val682 = new LogLevel();
+ _val682.read(iprot);
+ struct.named_logger_level.put(_key681, _val682);
}
iprot.readMapEnd();
}
@@ -404,10 +404,10 @@ public class LogConfig implements org.apache.thrift.TBase<LogConfig, LogConfig._
oprot.writeFieldBegin(NAMED_LOGGER_LEVEL_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.named_logger_level.size()));
- for (Map.Entry<String, LogLevel> _iter660 : struct.named_logger_level.entrySet())
+ for (Map.Entry<String, LogLevel> _iter684 : struct.named_logger_level.entrySet())
{
- oprot.writeString(_iter660.getKey());
- _iter660.getValue().write(oprot);
+ oprot.writeString(_iter684.getKey());
+ _iter684.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -439,10 +439,10 @@ public class LogConfig implements org.apache.thrift.TBase<LogConfig, LogConfig._
if (struct.is_set_named_logger_level()) {
{
oprot.writeI32(struct.named_logger_level.size());
- for (Map.Entry<String, LogLevel> _iter661 : struct.named_logger_level.entrySet())
+ for (Map.Entry<String, LogLevel> _iter685 : struct.named_logger_level.entrySet())
{
- oprot.writeString(_iter661.getKey());
- _iter661.getValue().write(oprot);
+ oprot.writeString(_iter685.getKey());
+ _iter685.getValue().write(oprot);
}
}
}
@@ -454,16 +454,16 @@ public class LogConfig implements org.apache.thrift.TBase<LogConfig, LogConfig._
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map662 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.named_logger_level = new HashMap<String,LogLevel>(2*_map662.size);
- String _key663;
- LogLevel _val664;
- for (int _i665 = 0; _i665 < _map662.size; ++_i665)
+ org.apache.thrift.protocol.TMap _map686 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.named_logger_level = new HashMap<String,LogLevel>(2*_map686.size);
+ String _key687;
+ LogLevel _val688;
+ for (int _i689 = 0; _i689 < _map686.size; ++_i689)
{
- _key663 = iprot.readString();
- _val664 = new LogLevel();
- _val664.read(iprot);
- struct.named_logger_level.put(_key663, _val664);
+ _key687 = iprot.readString();
+ _val688 = new LogLevel();
+ _val688.read(iprot);
+ struct.named_logger_level.put(_key687, _val688);
}
}
struct.set_named_logger_level_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/LogLevel.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/LogLevel.java b/storm-core/src/jvm/backtype/storm/generated/LogLevel.java
index 1526bf3..adc8e10 100644
--- a/storm-core/src/jvm/backtype/storm/generated/LogLevel.java
+++ b/storm-core/src/jvm/backtype/storm/generated/LogLevel.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class LogLevel implements org.apache.thrift.TBase<LogLevel, LogLevel._Fields>, java.io.Serializable, Cloneable, Comparable<LogLevel> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("LogLevel");
@@ -387,10 +387,10 @@ public class LogLevel implements org.apache.thrift.TBase<LogLevel, LogLevel._Fie
return get_target_log_level();
case RESET_LOG_LEVEL_TIMEOUT_SECS:
- return Integer.valueOf(get_reset_log_level_timeout_secs());
+ return get_reset_log_level_timeout_secs();
case RESET_LOG_LEVEL_TIMEOUT_EPOCH:
- return Long.valueOf(get_reset_log_level_timeout_epoch());
+ return get_reset_log_level_timeout_epoch();
case RESET_LOG_LEVEL:
return get_reset_log_level();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/LogLevelAction.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/LogLevelAction.java b/storm-core/src/jvm/backtype/storm/generated/LogLevelAction.java
index c649bcf..fed2365 100644
--- a/storm-core/src/jvm/backtype/storm/generated/LogLevelAction.java
+++ b/storm-core/src/jvm/backtype/storm/generated/LogLevelAction.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/Nimbus.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/Nimbus.java b/storm-core/src/jvm/backtype/storm/generated/Nimbus.java
index b0d007b..f8a94ab 100644
--- a/storm-core/src/jvm/backtype/storm/generated/Nimbus.java
+++ b/storm-core/src/jvm/backtype/storm/generated/Nimbus.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-11-4")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class Nimbus {
public interface Iface {
@@ -13165,10 +13165,10 @@ public class Nimbus {
return get_component();
case ENABLE:
- return Boolean.valueOf(is_enable());
+ return is_enable();
case SAMPLING_PERCENTAGE:
- return Double.valueOf(get_samplingPercentage());
+ return get_samplingPercentage();
}
throw new IllegalStateException();
@@ -24303,7 +24303,7 @@ public class Nimbus {
return get_window();
case IS_INCLUDE_SYS:
- return Boolean.valueOf(is_is_include_sys());
+ return is_is_include_sys();
}
throw new IllegalStateException();
@@ -25489,7 +25489,7 @@ public class Nimbus {
return get_window();
case IS_INCLUDE_SYS:
- return Boolean.valueOf(is_is_include_sys());
+ return is_is_include_sys();
}
throw new IllegalStateException();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/NimbusSummary.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/NimbusSummary.java b/storm-core/src/jvm/backtype/storm/generated/NimbusSummary.java
index 7d1e2fd..6278be8 100644
--- a/storm-core/src/jvm/backtype/storm/generated/NimbusSummary.java
+++ b/storm-core/src/jvm/backtype/storm/generated/NimbusSummary.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, NimbusSummary._Fields>, java.io.Serializable, Cloneable, Comparable<NimbusSummary> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("NimbusSummary");
@@ -381,13 +381,13 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, Nim
return get_host();
case PORT:
- return Integer.valueOf(get_port());
+ return get_port();
case UPTIME_SECS:
- return Integer.valueOf(get_uptime_secs());
+ return get_uptime_secs();
case IS_LEADER:
- return Boolean.valueOf(is_isLeader());
+ return is_isLeader();
case VERSION:
return get_version();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/NodeInfo.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/NodeInfo.java b/storm-core/src/jvm/backtype/storm/generated/NodeInfo.java
index 364afa7..a99ecb3 100644
--- a/storm-core/src/jvm/backtype/storm/generated/NodeInfo.java
+++ b/storm-core/src/jvm/backtype/storm/generated/NodeInfo.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class NodeInfo implements org.apache.thrift.TBase<NodeInfo, NodeInfo._Fields>, java.io.Serializable, Cloneable, Comparable<NodeInfo> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("NodeInfo");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/NotAliveException.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/NotAliveException.java b/storm-core/src/jvm/backtype/storm/generated/NotAliveException.java
index cbabcf9..275e8ec 100644
--- a/storm-core/src/jvm/backtype/storm/generated/NotAliveException.java
+++ b/storm-core/src/jvm/backtype/storm/generated/NotAliveException.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class NotAliveException extends TException implements org.apache.thrift.TBase<NotAliveException, NotAliveException._Fields>, java.io.Serializable, Cloneable, Comparable<NotAliveException> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("NotAliveException");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/NullStruct.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/NullStruct.java b/storm-core/src/jvm/backtype/storm/generated/NullStruct.java
index 1b8208c..9949c2f 100644
--- a/storm-core/src/jvm/backtype/storm/generated/NullStruct.java
+++ b/storm-core/src/jvm/backtype/storm/generated/NullStruct.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class NullStruct implements org.apache.thrift.TBase<NullStruct, NullStruct._Fields>, java.io.Serializable, Cloneable, Comparable<NullStruct> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("NullStruct");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/NumErrorsChoice.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/NumErrorsChoice.java b/storm-core/src/jvm/backtype/storm/generated/NumErrorsChoice.java
index 8da6671..17970bc 100644
--- a/storm-core/src/jvm/backtype/storm/generated/NumErrorsChoice.java
+++ b/storm-core/src/jvm/backtype/storm/generated/NumErrorsChoice.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/ProfileAction.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ProfileAction.java b/storm-core/src/jvm/backtype/storm/generated/ProfileAction.java
index 584fd03..635a25d 100644
--- a/storm-core/src/jvm/backtype/storm/generated/ProfileAction.java
+++ b/storm-core/src/jvm/backtype/storm/generated/ProfileAction.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/ProfileRequest.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ProfileRequest.java b/storm-core/src/jvm/backtype/storm/generated/ProfileRequest.java
index a3a98ae..42560b5 100644
--- a/storm-core/src/jvm/backtype/storm/generated/ProfileRequest.java
+++ b/storm-core/src/jvm/backtype/storm/generated/ProfileRequest.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-24")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class ProfileRequest implements org.apache.thrift.TBase<ProfileRequest, ProfileRequest._Fields>, java.io.Serializable, Cloneable, Comparable<ProfileRequest> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ProfileRequest");
@@ -306,7 +306,7 @@ public class ProfileRequest implements org.apache.thrift.TBase<ProfileRequest, P
return get_action();
case TIME_STAMP:
- return Long.valueOf(get_time_stamp());
+ return get_time_stamp();
}
throw new IllegalStateException();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/RebalanceOptions.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/RebalanceOptions.java b/storm-core/src/jvm/backtype/storm/generated/RebalanceOptions.java
index d859f5a..03c36da 100644
--- a/storm-core/src/jvm/backtype/storm/generated/RebalanceOptions.java
+++ b/storm-core/src/jvm/backtype/storm/generated/RebalanceOptions.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class RebalanceOptions implements org.apache.thrift.TBase<RebalanceOptions, RebalanceOptions._Fields>, java.io.Serializable, Cloneable, Comparable<RebalanceOptions> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("RebalanceOptions");
@@ -292,10 +292,10 @@ public class RebalanceOptions implements org.apache.thrift.TBase<RebalanceOption
public Object getFieldValue(_Fields field) {
switch (field) {
case WAIT_SECS:
- return Integer.valueOf(get_wait_secs());
+ return get_wait_secs();
case NUM_WORKERS:
- return Integer.valueOf(get_num_workers());
+ return get_num_workers();
case NUM_EXECUTORS:
return get_num_executors();
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/ShellComponent.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ShellComponent.java b/storm-core/src/jvm/backtype/storm/generated/ShellComponent.java
index ab86c6a..72c09ab 100644
--- a/storm-core/src/jvm/backtype/storm/generated/ShellComponent.java
+++ b/storm-core/src/jvm/backtype/storm/generated/ShellComponent.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class ShellComponent implements org.apache.thrift.TBase<ShellComponent, ShellComponent._Fields>, java.io.Serializable, Cloneable, Comparable<ShellComponent> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ShellComponent");
http://git-wip-us.apache.org/repos/asf/storm/blob/73650789/storm-core/src/jvm/backtype/storm/generated/SpecificAggregateStats.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/SpecificAggregateStats.java b/storm-core/src/jvm/backtype/storm/generated/SpecificAggregateStats.java
index ed143f0..ccdb919 100644
--- a/storm-core/src/jvm/backtype/storm/generated/SpecificAggregateStats.java
+++ b/storm-core/src/jvm/backtype/storm/generated/SpecificAggregateStats.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
[4/6] storm git commit: Switching file mode back on genthrift.
Posted by bo...@apache.org.
Switching file mode back on genthrift.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/c29c2b66
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/c29c2b66
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/c29c2b66
Branch: refs/heads/master
Commit: c29c2b66f8ab469c44a148d44a11b0a523948940
Parents: 7365078
Author: Kyle Nusbaum <Ky...@gmail.com>
Authored: Tue Nov 10 14:40:25 2015 -0600
Committer: Kyle Nusbaum <Ky...@gmail.com>
Committed: Tue Nov 10 14:40:25 2015 -0600
----------------------------------------------------------------------
storm-core/src/genthrift.sh | 0
1 file changed, 0 insertions(+), 0 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/c29c2b66/storm-core/src/genthrift.sh
----------------------------------------------------------------------
diff --git a/storm-core/src/genthrift.sh b/storm-core/src/genthrift.sh
old mode 100755
new mode 100644