storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [1/6] storm git commit: Upgrading to thrift 0.9.3
Date Thu, 12 Nov 2015 14:31:10 GMT
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:


Mime
View raw message