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/10/05 23:00:49 UTC
[17/37] storm git commit: Renumber thrift struct fields consistently
from 1
http://git-wip-us.apache.org/repos/asf/storm/blob/a6b82f8b/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 a971023..0bcc164 100644
--- a/storm-core/src/py/storm/ttypes.py
+++ b/storm-core/src/py/storm/ttypes.py
@@ -4286,5094 +4286,1001 @@ class CommonAggregateStats:
thrift_spec = (
None, # 0
- None, # 1
- None, # 2
- None, # 3
- None, # 4
- None, # 5
- None, # 6
- None, # 7
- None, # 8
- None, # 9
- None, # 10
- None, # 11
- None, # 12
- None, # 13
- None, # 14
- None, # 15
- None, # 16
- None, # 17
- None, # 18
- None, # 19
- None, # 20
- None, # 21
- None, # 22
- None, # 23
- None, # 24
- None, # 25
- None, # 26
- None, # 27
- None, # 28
- None, # 29
- None, # 30
- None, # 31
- None, # 32
- None, # 33
- None, # 34
- None, # 35
- None, # 36
- None, # 37
- None, # 38
- None, # 39
- None, # 40
- None, # 41
- None, # 42
- None, # 43
- None, # 44
- None, # 45
- None, # 46
- None, # 47
- None, # 48
- None, # 49
- None, # 50
- None, # 51
- None, # 52
- None, # 53
- None, # 54
- None, # 55
- None, # 56
- None, # 57
- None, # 58
- None, # 59
- None, # 60
- None, # 61
- None, # 62
- None, # 63
- None, # 64
- None, # 65
- None, # 66
- None, # 67
- None, # 68
- None, # 69
- None, # 70
- None, # 71
- None, # 72
- None, # 73
- None, # 74
- None, # 75
- None, # 76
- None, # 77
- None, # 78
- None, # 79
- None, # 80
- None, # 81
- None, # 82
- None, # 83
- None, # 84
- None, # 85
- None, # 86
- None, # 87
- None, # 88
- None, # 89
- None, # 90
- None, # 91
- None, # 92
- None, # 93
- None, # 94
- None, # 95
- None, # 96
- None, # 97
- None, # 98
- None, # 99
- None, # 100
- None, # 101
- None, # 102
- None, # 103
- None, # 104
- None, # 105
- None, # 106
- None, # 107
- None, # 108
- None, # 109
- None, # 110
- None, # 111
- None, # 112
- None, # 113
- None, # 114
- None, # 115
- None, # 116
- None, # 117
- None, # 118
- None, # 119
- None, # 120
- None, # 121
- None, # 122
- None, # 123
- None, # 124
- None, # 125
- None, # 126
- None, # 127
- None, # 128
- None, # 129
- None, # 130
- None, # 131
- None, # 132
- None, # 133
- None, # 134
- None, # 135
- None, # 136
- None, # 137
- None, # 138
- None, # 139
- None, # 140
- None, # 141
- None, # 142
- None, # 143
- None, # 144
- None, # 145
- None, # 146
- None, # 147
- None, # 148
- None, # 149
- None, # 150
- None, # 151
- None, # 152
- None, # 153
- None, # 154
- None, # 155
- None, # 156
- None, # 157
- None, # 158
- None, # 159
- None, # 160
- None, # 161
- None, # 162
- None, # 163
- None, # 164
- None, # 165
- None, # 166
- None, # 167
- None, # 168
- None, # 169
- None, # 170
- None, # 171
- None, # 172
- None, # 173
- None, # 174
- None, # 175
- None, # 176
- None, # 177
- None, # 178
- None, # 179
- None, # 180
- None, # 181
- None, # 182
- None, # 183
- None, # 184
- None, # 185
- None, # 186
- None, # 187
- None, # 188
- None, # 189
- None, # 190
- None, # 191
- None, # 192
- None, # 193
- None, # 194
- None, # 195
- None, # 196
- None, # 197
- None, # 198
- None, # 199
- None, # 200
- None, # 201
- None, # 202
- None, # 203
- None, # 204
- None, # 205
- None, # 206
- None, # 207
- None, # 208
- None, # 209
- None, # 210
- None, # 211
- None, # 212
- None, # 213
- None, # 214
- None, # 215
- None, # 216
- None, # 217
- None, # 218
- None, # 219
- None, # 220
- None, # 221
- None, # 222
- None, # 223
- None, # 224
- None, # 225
- None, # 226
- None, # 227
- None, # 228
- None, # 229
- None, # 230
- None, # 231
- None, # 232
- None, # 233
- None, # 234
- None, # 235
- None, # 236
- None, # 237
- None, # 238
- None, # 239
- None, # 240
- None, # 241
- None, # 242
- None, # 243
- None, # 244
- None, # 245
- None, # 246
- None, # 247
- None, # 248
- None, # 249
- None, # 250
- None, # 251
- None, # 252
- None, # 253
- None, # 254
- None, # 255
- None, # 256
- None, # 257
- None, # 258
- None, # 259
- None, # 260
- None, # 261
- None, # 262
- None, # 263
- None, # 264
- None, # 265
- None, # 266
- None, # 267
- None, # 268
- None, # 269
- None, # 270
- None, # 271
- None, # 272
- None, # 273
- None, # 274
- None, # 275
- None, # 276
- None, # 277
- None, # 278
- None, # 279
- None, # 280
- None, # 281
- None, # 282
- None, # 283
- None, # 284
- None, # 285
- None, # 286
- None, # 287
- None, # 288
- None, # 289
- None, # 290
- None, # 291
- None, # 292
- None, # 293
- None, # 294
- None, # 295
- None, # 296
- None, # 297
- None, # 298
- None, # 299
- None, # 300
- None, # 301
- None, # 302
- None, # 303
- None, # 304
- None, # 305
- None, # 306
- None, # 307
- None, # 308
- None, # 309
- None, # 310
- None, # 311
- None, # 312
- None, # 313
- None, # 314
- None, # 315
- None, # 316
- None, # 317
- None, # 318
- None, # 319
- None, # 320
- None, # 321
- None, # 322
- None, # 323
- None, # 324
- None, # 325
- None, # 326
- None, # 327
- None, # 328
- None, # 329
- None, # 330
- None, # 331
- None, # 332
- None, # 333
- None, # 334
- None, # 335
- None, # 336
- None, # 337
- None, # 338
- None, # 339
- None, # 340
- None, # 341
- None, # 342
- None, # 343
- None, # 344
- None, # 345
- None, # 346
- None, # 347
- None, # 348
- None, # 349
- None, # 350
- None, # 351
- None, # 352
- None, # 353
- None, # 354
- None, # 355
- None, # 356
- None, # 357
- None, # 358
- None, # 359
- None, # 360
- None, # 361
- None, # 362
- None, # 363
- None, # 364
- None, # 365
- None, # 366
- None, # 367
- None, # 368
- None, # 369
- None, # 370
- None, # 371
- None, # 372
- None, # 373
- None, # 374
- None, # 375
- None, # 376
- None, # 377
- None, # 378
- None, # 379
- None, # 380
- None, # 381
- None, # 382
- None, # 383
- None, # 384
- None, # 385
- None, # 386
- None, # 387
- None, # 388
- None, # 389
- None, # 390
- None, # 391
- None, # 392
- None, # 393
- None, # 394
- None, # 395
- None, # 396
- None, # 397
- None, # 398
- None, # 399
- None, # 400
- None, # 401
- None, # 402
- None, # 403
- None, # 404
- None, # 405
- None, # 406
- None, # 407
- None, # 408
- None, # 409
- None, # 410
- None, # 411
- None, # 412
- None, # 413
- None, # 414
- None, # 415
- None, # 416
- None, # 417
- None, # 418
- None, # 419
- None, # 420
- None, # 421
- None, # 422
- None, # 423
- None, # 424
- None, # 425
- None, # 426
- None, # 427
- None, # 428
- None, # 429
- None, # 430
- None, # 431
- None, # 432
- None, # 433
- None, # 434
- None, # 435
- None, # 436
- None, # 437
- None, # 438
- None, # 439
- None, # 440
- None, # 441
- None, # 442
- None, # 443
- None, # 444
- None, # 445
- None, # 446
- None, # 447
- None, # 448
- None, # 449
- None, # 450
- None, # 451
- None, # 452
- None, # 453
- None, # 454
- None, # 455
- None, # 456
- None, # 457
- None, # 458
- None, # 459
- None, # 460
- None, # 461
- None, # 462
- None, # 463
- None, # 464
- None, # 465
- None, # 466
- None, # 467
- None, # 468
- None, # 469
- None, # 470
- None, # 471
- None, # 472
- None, # 473
- None, # 474
- None, # 475
- None, # 476
- None, # 477
- None, # 478
- None, # 479
- None, # 480
- None, # 481
- None, # 482
- None, # 483
- None, # 484
- None, # 485
- None, # 486
- None, # 487
- None, # 488
- None, # 489
- None, # 490
- None, # 491
- None, # 492
- None, # 493
- None, # 494
- None, # 495
- None, # 496
- None, # 497
- None, # 498
- None, # 499
- None, # 500
- None, # 501
- None, # 502
- None, # 503
- None, # 504
- None, # 505
- None, # 506
- None, # 507
- None, # 508
- None, # 509
- None, # 510
- None, # 511
- None, # 512
- (513, TType.I32, 'num_executors', None, None, ), # 513
- (514, TType.I32, 'num_tasks', None, None, ), # 514
- (515, TType.I64, 'emitted', None, None, ), # 515
- (516, TType.I64, 'transferred', None, None, ), # 516
- (517, TType.I64, 'acked', None, None, ), # 517
- (518, TType.I64, 'failed', None, None, ), # 518
- )
-
- def __init__(self, num_executors=None, num_tasks=None, emitted=None, transferred=None, acked=None, failed=None,):
- self.num_executors = num_executors
- self.num_tasks = num_tasks
- self.emitted = emitted
- self.transferred = transferred
- self.acked = acked
- self.failed = failed
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 513:
- if ftype == TType.I32:
- self.num_executors = iprot.readI32();
- else:
- iprot.skip(ftype)
- elif fid == 514:
- if ftype == TType.I32:
- self.num_tasks = iprot.readI32();
- else:
- iprot.skip(ftype)
- elif fid == 515:
- if ftype == TType.I64:
- self.emitted = iprot.readI64();
- else:
- iprot.skip(ftype)
- elif fid == 516:
- if ftype == TType.I64:
- self.transferred = iprot.readI64();
- else:
- iprot.skip(ftype)
- elif fid == 517:
- if ftype == TType.I64:
- self.acked = iprot.readI64();
- else:
- iprot.skip(ftype)
- elif fid == 518:
- if ftype == TType.I64:
- self.failed = iprot.readI64();
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('CommonAggregateStats')
- if self.num_executors is not None:
- oprot.writeFieldBegin('num_executors', TType.I32, 513)
- oprot.writeI32(self.num_executors)
- oprot.writeFieldEnd()
- if self.num_tasks is not None:
- oprot.writeFieldBegin('num_tasks', TType.I32, 514)
- oprot.writeI32(self.num_tasks)
- oprot.writeFieldEnd()
- if self.emitted is not None:
- oprot.writeFieldBegin('emitted', TType.I64, 515)
- oprot.writeI64(self.emitted)
- oprot.writeFieldEnd()
- if self.transferred is not None:
- oprot.writeFieldBegin('transferred', TType.I64, 516)
- oprot.writeI64(self.transferred)
- oprot.writeFieldEnd()
- if self.acked is not None:
- oprot.writeFieldBegin('acked', TType.I64, 517)
- oprot.writeI64(self.acked)
- oprot.writeFieldEnd()
- if self.failed is not None:
- oprot.writeFieldBegin('failed', TType.I64, 518)
- oprot.writeI64(self.failed)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.num_executors)
- value = (value * 31) ^ hash(self.num_tasks)
- value = (value * 31) ^ hash(self.emitted)
- value = (value * 31) ^ hash(self.transferred)
- value = (value * 31) ^ hash(self.acked)
- value = (value * 31) ^ hash(self.failed)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class SpoutAggregateStats:
- """
- Attributes:
- - complete_latency_ms
- """
-
- thrift_spec = (
- None, # 0
- None, # 1
- None, # 2
- None, # 3
- None, # 4
- None, # 5
- None, # 6
- None, # 7
- None, # 8
- None, # 9
- None, # 10
- None, # 11
- None, # 12
- None, # 13
- None, # 14
- None, # 15
- None, # 16
- None, # 17
- None, # 18
- None, # 19
- None, # 20
- None, # 21
- None, # 22
- None, # 23
- None, # 24
- None, # 25
- None, # 26
- None, # 27
- None, # 28
- None, # 29
- None, # 30
- None, # 31
- None, # 32
- None, # 33
- None, # 34
- None, # 35
- None, # 36
- None, # 37
- None, # 38
- None, # 39
- None, # 40
- None, # 41
- None, # 42
- None, # 43
- None, # 44
- None, # 45
- None, # 46
- None, # 47
- None, # 48
- None, # 49
- None, # 50
- None, # 51
- None, # 52
- None, # 53
- None, # 54
- None, # 55
- None, # 56
- None, # 57
- None, # 58
- None, # 59
- None, # 60
- None, # 61
- None, # 62
- None, # 63
- None, # 64
- None, # 65
- None, # 66
- None, # 67
- None, # 68
- None, # 69
- None, # 70
- None, # 71
- None, # 72
- None, # 73
- None, # 74
- None, # 75
- None, # 76
- None, # 77
- None, # 78
- None, # 79
- None, # 80
- None, # 81
- None, # 82
- None, # 83
- None, # 84
- None, # 85
- None, # 86
- None, # 87
- None, # 88
- None, # 89
- None, # 90
- None, # 91
- None, # 92
- None, # 93
- None, # 94
- None, # 95
- None, # 96
- None, # 97
- None, # 98
- None, # 99
- None, # 100
- None, # 101
- None, # 102
- None, # 103
- None, # 104
- None, # 105
- None, # 106
- None, # 107
- None, # 108
- None, # 109
- None, # 110
- None, # 111
- None, # 112
- None, # 113
- None, # 114
- None, # 115
- None, # 116
- None, # 117
- None, # 118
- None, # 119
- None, # 120
- None, # 121
- None, # 122
- None, # 123
- None, # 124
- None, # 125
- None, # 126
- None, # 127
- None, # 128
- None, # 129
- None, # 130
- None, # 131
- None, # 132
- None, # 133
- None, # 134
- None, # 135
- None, # 136
- None, # 137
- None, # 138
- None, # 139
- None, # 140
- None, # 141
- None, # 142
- None, # 143
- None, # 144
- None, # 145
- None, # 146
- None, # 147
- None, # 148
- None, # 149
- None, # 150
- None, # 151
- None, # 152
- None, # 153
- None, # 154
- None, # 155
- None, # 156
- None, # 157
- None, # 158
- None, # 159
- None, # 160
- None, # 161
- None, # 162
- None, # 163
- None, # 164
- None, # 165
- None, # 166
- None, # 167
- None, # 168
- None, # 169
- None, # 170
- None, # 171
- None, # 172
- None, # 173
- None, # 174
- None, # 175
- None, # 176
- None, # 177
- None, # 178
- None, # 179
- None, # 180
- None, # 181
- None, # 182
- None, # 183
- None, # 184
- None, # 185
- None, # 186
- None, # 187
- None, # 188
- None, # 189
- None, # 190
- None, # 191
- None, # 192
- None, # 193
- None, # 194
- None, # 195
- None, # 196
- None, # 197
- None, # 198
- None, # 199
- None, # 200
- None, # 201
- None, # 202
- None, # 203
- None, # 204
- None, # 205
- None, # 206
- None, # 207
- None, # 208
- None, # 209
- None, # 210
- None, # 211
- None, # 212
- None, # 213
- None, # 214
- None, # 215
- None, # 216
- None, # 217
- None, # 218
- None, # 219
- None, # 220
- None, # 221
- None, # 222
- None, # 223
- None, # 224
- None, # 225
- None, # 226
- None, # 227
- None, # 228
- None, # 229
- None, # 230
- None, # 231
- None, # 232
- None, # 233
- None, # 234
- None, # 235
- None, # 236
- None, # 237
- None, # 238
- None, # 239
- None, # 240
- None, # 241
- None, # 242
- None, # 243
- None, # 244
- None, # 245
- None, # 246
- None, # 247
- None, # 248
- None, # 249
- None, # 250
- None, # 251
- None, # 252
- None, # 253
- None, # 254
- None, # 255
- None, # 256
- None, # 257
- None, # 258
- None, # 259
- None, # 260
- None, # 261
- None, # 262
- None, # 263
- None, # 264
- None, # 265
- None, # 266
- None, # 267
- None, # 268
- None, # 269
- None, # 270
- None, # 271
- None, # 272
- None, # 273
- None, # 274
- None, # 275
- None, # 276
- None, # 277
- None, # 278
- None, # 279
- None, # 280
- None, # 281
- None, # 282
- None, # 283
- None, # 284
- None, # 285
- None, # 286
- None, # 287
- None, # 288
- None, # 289
- None, # 290
- None, # 291
- None, # 292
- None, # 293
- None, # 294
- None, # 295
- None, # 296
- None, # 297
- None, # 298
- None, # 299
- None, # 300
- None, # 301
- None, # 302
- None, # 303
- None, # 304
- None, # 305
- None, # 306
- None, # 307
- None, # 308
- None, # 309
- None, # 310
- None, # 311
- None, # 312
- None, # 313
- None, # 314
- None, # 315
- None, # 316
- None, # 317
- None, # 318
- None, # 319
- None, # 320
- None, # 321
- None, # 322
- None, # 323
- None, # 324
- None, # 325
- None, # 326
- None, # 327
- None, # 328
- None, # 329
- None, # 330
- None, # 331
- None, # 332
- None, # 333
- None, # 334
- None, # 335
- None, # 336
- None, # 337
- None, # 338
- None, # 339
- None, # 340
- None, # 341
- None, # 342
- None, # 343
- None, # 344
- None, # 345
- None, # 346
- None, # 347
- None, # 348
- None, # 349
- None, # 350
- None, # 351
- None, # 352
- None, # 353
- None, # 354
- None, # 355
- None, # 356
- None, # 357
- None, # 358
- None, # 359
- None, # 360
- None, # 361
- None, # 362
- None, # 363
- None, # 364
- None, # 365
- None, # 366
- None, # 367
- None, # 368
- None, # 369
- None, # 370
- None, # 371
- None, # 372
- None, # 373
- None, # 374
- None, # 375
- None, # 376
- None, # 377
- None, # 378
- None, # 379
- None, # 380
- None, # 381
- None, # 382
- None, # 383
- None, # 384
- None, # 385
- None, # 386
- None, # 387
- None, # 388
- None, # 389
- None, # 390
- None, # 391
- None, # 392
- None, # 393
- None, # 394
- None, # 395
- None, # 396
- None, # 397
- None, # 398
- None, # 399
- None, # 400
- None, # 401
- None, # 402
- None, # 403
- None, # 404
- None, # 405
- None, # 406
- None, # 407
- None, # 408
- None, # 409
- None, # 410
- None, # 411
- None, # 412
- None, # 413
- None, # 414
- None, # 415
- None, # 416
- None, # 417
- None, # 418
- None, # 419
- None, # 420
- None, # 421
- None, # 422
- None, # 423
- None, # 424
- None, # 425
- None, # 426
- None, # 427
- None, # 428
- None, # 429
- None, # 430
- None, # 431
- None, # 432
- None, # 433
- None, # 434
- None, # 435
- None, # 436
- None, # 437
- None, # 438
- None, # 439
- None, # 440
- None, # 441
- None, # 442
- None, # 443
- None, # 444
- None, # 445
- None, # 446
- None, # 447
- None, # 448
- None, # 449
- None, # 450
- None, # 451
- None, # 452
- None, # 453
- None, # 454
- None, # 455
- None, # 456
- None, # 457
- None, # 458
- None, # 459
- None, # 460
- None, # 461
- None, # 462
- None, # 463
- None, # 464
- None, # 465
- None, # 466
- None, # 467
- None, # 468
- None, # 469
- None, # 470
- None, # 471
- None, # 472
- None, # 473
- None, # 474
- None, # 475
- None, # 476
- None, # 477
- None, # 478
- None, # 479
- None, # 480
- None, # 481
- None, # 482
- None, # 483
- None, # 484
- None, # 485
- None, # 486
- None, # 487
- None, # 488
- None, # 489
- None, # 490
- None, # 491
- None, # 492
- None, # 493
- None, # 494
- None, # 495
- None, # 496
- None, # 497
- None, # 498
- None, # 499
- None, # 500
- None, # 501
- None, # 502
- None, # 503
- None, # 504
- None, # 505
- None, # 506
- None, # 507
- None, # 508
- None, # 509
- None, # 510
- None, # 511
- None, # 512
- (513, TType.DOUBLE, 'complete_latency_ms', None, None, ), # 513
- )
-
- def __init__(self, complete_latency_ms=None,):
- self.complete_latency_ms = complete_latency_ms
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 513:
- if ftype == TType.DOUBLE:
- self.complete_latency_ms = iprot.readDouble();
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('SpoutAggregateStats')
- if self.complete_latency_ms is not None:
- oprot.writeFieldBegin('complete_latency_ms', TType.DOUBLE, 513)
- oprot.writeDouble(self.complete_latency_ms)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.complete_latency_ms)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class BoltAggregateStats:
- """
- Attributes:
- - execute_latency_ms
- - process_latency_ms
- - executed
- - capacity
- """
-
- thrift_spec = (
- None, # 0
- None, # 1
- None, # 2
- None, # 3
- None, # 4
- None, # 5
- None, # 6
- None, # 7
- None, # 8
- None, # 9
- None, # 10
- None, # 11
- None, # 12
- None, # 13
- None, # 14
- None, # 15
- None, # 16
- None, # 17
- None, # 18
- None, # 19
- None, # 20
- None, # 21
- None, # 22
- None, # 23
- None, # 24
- None, # 25
- None, # 26
- None, # 27
- None, # 28
- None, # 29
- None, # 30
- None, # 31
- None, # 32
- None, # 33
- None, # 34
- None, # 35
- None, # 36
- None, # 37
- None, # 38
- None, # 39
- None, # 40
- None, # 41
- None, # 42
- None, # 43
- None, # 44
- None, # 45
- None, # 46
- None, # 47
- None, # 48
- None, # 49
- None, # 50
- None, # 51
- None, # 52
- None, # 53
- None, # 54
- None, # 55
- None, # 56
- None, # 57
- None, # 58
- None, # 59
- None, # 60
- None, # 61
- None, # 62
- None, # 63
- None, # 64
- None, # 65
- None, # 66
- None, # 67
- None, # 68
- None, # 69
- None, # 70
- None, # 71
- None, # 72
- None, # 73
- None, # 74
- None, # 75
- None, # 76
- None, # 77
- None, # 78
- None, # 79
- None, # 80
- None, # 81
- None, # 82
- None, # 83
- None, # 84
- None, # 85
- None, # 86
- None, # 87
- None, # 88
- None, # 89
- None, # 90
- None, # 91
- None, # 92
- None, # 93
- None, # 94
- None, # 95
- None, # 96
- None, # 97
- None, # 98
- None, # 99
- None, # 100
- None, # 101
- None, # 102
- None, # 103
- None, # 104
- None, # 105
- None, # 106
- None, # 107
- None, # 108
- None, # 109
- None, # 110
- None, # 111
- None, # 112
- None, # 113
- None, # 114
- None, # 115
- None, # 116
- None, # 117
- None, # 118
- None, # 119
- None, # 120
- None, # 121
- None, # 122
- None, # 123
- None, # 124
- None, # 125
- None, # 126
- None, # 127
- None, # 128
- None, # 129
- None, # 130
- None, # 131
- None, # 132
- None, # 133
- None, # 134
- None, # 135
- None, # 136
- None, # 137
- None, # 138
- None, # 139
- None, # 140
- None, # 141
- None, # 142
- None, # 143
- None, # 144
- None, # 145
- None, # 146
- None, # 147
- None, # 148
- None, # 149
- None, # 150
- None, # 151
- None, # 152
- None, # 153
- None, # 154
- None, # 155
- None, # 156
- None, # 157
- None, # 158
- None, # 159
- None, # 160
- None, # 161
- None, # 162
- None, # 163
- None, # 164
- None, # 165
- None, # 166
- None, # 167
- None, # 168
- None, # 169
- None, # 170
- None, # 171
- None, # 172
- None, # 173
- None, # 174
- None, # 175
- None, # 176
- None, # 177
- None, # 178
- None, # 179
- None, # 180
- None, # 181
- None, # 182
- None, # 183
- None, # 184
- None, # 185
- None, # 186
- None, # 187
- None, # 188
- None, # 189
- None, # 190
- None, # 191
- None, # 192
- None, # 193
- None, # 194
- None, # 195
- None, # 196
- None, # 197
- None, # 198
- None, # 199
- None, # 200
- None, # 201
- None, # 202
- None, # 203
- None, # 204
- None, # 205
- None, # 206
- None, # 207
- None, # 208
- None, # 209
- None, # 210
- None, # 211
- None, # 212
- None, # 213
- None, # 214
- None, # 215
- None, # 216
- None, # 217
- None, # 218
- None, # 219
- None, # 220
- None, # 221
- None, # 222
- None, # 223
- None, # 224
- None, # 225
- None, # 226
- None, # 227
- None, # 228
- None, # 229
- None, # 230
- None, # 231
- None, # 232
- None, # 233
- None, # 234
- None, # 235
- None, # 236
- None, # 237
- None, # 238
- None, # 239
- None, # 240
- None, # 241
- None, # 242
- None, # 243
- None, # 244
- None, # 245
- None, # 246
- None, # 247
- None, # 248
- None, # 249
- None, # 250
- None, # 251
- None, # 252
- None, # 253
- None, # 254
- None, # 255
- None, # 256
- None, # 257
- None, # 258
- None, # 259
- None, # 260
- None, # 261
- None, # 262
- None, # 263
- None, # 264
- None, # 265
- None, # 266
- None, # 267
- None, # 268
- None, # 269
- None, # 270
- None, # 271
- None, # 272
- None, # 273
- None, # 274
- None, # 275
- None, # 276
- None, # 277
- None, # 278
- None, # 279
- None, # 280
- None, # 281
- None, # 282
- None, # 283
- None, # 284
- None, # 285
- None, # 286
- None, # 287
- None, # 288
- None, # 289
- None, # 290
- None, # 291
- None, # 292
- None, # 293
- None, # 294
- None, # 295
- None, # 296
- None, # 297
- None, # 298
- None, # 299
- None, # 300
- None, # 301
- None, # 302
- None, # 303
- None, # 304
- None, # 305
- None, # 306
- None, # 307
- None, # 308
- None, # 309
- None, # 310
- None, # 311
- None, # 312
- None, # 313
- None, # 314
- None, # 315
- None, # 316
- None, # 317
- None, # 318
- None, # 319
- None, # 320
- None, # 321
- None, # 322
- None, # 323
- None, # 324
- None, # 325
- None, # 326
- None, # 327
- None, # 328
- None, # 329
- None, # 330
- None, # 331
- None, # 332
- None, # 333
- None, # 334
- None, # 335
- None, # 336
- None, # 337
- None, # 338
- None, # 339
- None, # 340
- None, # 341
- None, # 342
- None, # 343
- None, # 344
- None, # 345
- None, # 346
- None, # 347
- None, # 348
- None, # 349
- None, # 350
- None, # 351
- None, # 352
- None, # 353
- None, # 354
- None, # 355
- None, # 356
- None, # 357
- None, # 358
- None, # 359
- None, # 360
- None, # 361
- None, # 362
- None, # 363
- None, # 364
- None, # 365
- None, # 366
- None, # 367
- None, # 368
- None, # 369
- None, # 370
- None, # 371
- None, # 372
- None, # 373
- None, # 374
- None, # 375
- None, # 376
- None, # 377
- None, # 378
- None, # 379
- None, # 380
- None, # 381
- None, # 382
- None, # 383
- None, # 384
- None, # 385
- None, # 386
- None, # 387
- None, # 388
- None, # 389
- None, # 390
- None, # 391
- None, # 392
- None, # 393
- None, # 394
- None, # 395
- None, # 396
- None, # 397
- None, # 398
- None, # 399
- None, # 400
- None, # 401
- None, # 402
- None, # 403
- None, # 404
- None, # 405
- None, # 406
- None, # 407
- None, # 408
- None, # 409
- None, # 410
- None, # 411
- None, # 412
- None, # 413
- None, # 414
- None, # 415
- None, # 416
- None, # 417
- None, # 418
- None, # 419
- None, # 420
- None, # 421
- None, # 422
- None, # 423
- None, # 424
- None, # 425
- None, # 426
- None, # 427
- None, # 428
- None, # 429
- None, # 430
- None, # 431
- None, # 432
- None, # 433
- None, # 434
- None, # 435
- None, # 436
- None, # 437
- None, # 438
- None, # 439
- None, # 440
- None, # 441
- None, # 442
- None, # 443
- None, # 444
- None, # 445
- None, # 446
- None, # 447
- None, # 448
- None, # 449
- None, # 450
- None, # 451
- None, # 452
- None, # 453
- None, # 454
- None, # 455
- None, # 456
- None, # 457
- None, # 458
- None, # 459
- None, # 460
- None, # 461
- None, # 462
- None, # 463
- None, # 464
- None, # 465
- None, # 466
- None, # 467
- None, # 468
- None, # 469
- None, # 470
- None, # 471
- None, # 472
- None, # 473
- None, # 474
- None, # 475
- None, # 476
- None, # 477
- None, # 478
- None, # 479
- None, # 480
- None, # 481
- None, # 482
- None, # 483
- None, # 484
- None, # 485
- None, # 486
- None, # 487
- None, # 488
- None, # 489
- None, # 490
- None, # 491
- None, # 492
- None, # 493
- None, # 494
- None, # 495
- None, # 496
- None, # 497
- None, # 498
- None, # 499
- None, # 500
- None, # 501
- None, # 502
- None, # 503
- None, # 504
- None, # 505
- None, # 506
- None, # 507
- None, # 508
- None, # 509
- None, # 510
- None, # 511
- None, # 512
- (513, TType.DOUBLE, 'execute_latency_ms', None, None, ), # 513
- (514, TType.DOUBLE, 'process_latency_ms', None, None, ), # 514
- (515, TType.I64, 'executed', None, None, ), # 515
- (516, TType.DOUBLE, 'capacity', None, None, ), # 516
- )
-
- def __init__(self, execute_latency_ms=None, process_latency_ms=None, executed=None, capacity=None,):
- self.execute_latency_ms = execute_latency_ms
- self.process_latency_ms = process_latency_ms
- self.executed = executed
- self.capacity = capacity
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 513:
- if ftype == TType.DOUBLE:
- self.execute_latency_ms = iprot.readDouble();
- else:
- iprot.skip(ftype)
- elif fid == 514:
- if ftype == TType.DOUBLE:
- self.process_latency_ms = iprot.readDouble();
- else:
- iprot.skip(ftype)
- elif fid == 515:
- if ftype == TType.I64:
- self.executed = iprot.readI64();
- else:
- iprot.skip(ftype)
- elif fid == 516:
- if ftype == TType.DOUBLE:
- self.capacity = iprot.readDouble();
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('BoltAggregateStats')
- if self.execute_latency_ms is not None:
- oprot.writeFieldBegin('execute_latency_ms', TType.DOUBLE, 513)
- oprot.writeDouble(self.execute_latency_ms)
- oprot.writeFieldEnd()
- if self.process_latency_ms is not None:
- oprot.writeFieldBegin('process_latency_ms', TType.DOUBLE, 514)
- oprot.writeDouble(self.process_latency_ms)
- oprot.writeFieldEnd()
- if self.executed is not None:
- oprot.writeFieldBegin('executed', TType.I64, 515)
- oprot.writeI64(self.executed)
- oprot.writeFieldEnd()
- if self.capacity is not None:
- oprot.writeFieldBegin('capacity', TType.DOUBLE, 516)
- oprot.writeDouble(self.capacity)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.execute_latency_ms)
- value = (value * 31) ^ hash(self.process_latency_ms)
- value = (value * 31) ^ hash(self.executed)
- value = (value * 31) ^ hash(self.capacity)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class SpecificAggregateStats:
- """
- Attributes:
- - bolt
- - spout
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRUCT, 'bolt', (BoltAggregateStats, BoltAggregateStats.thrift_spec), None, ), # 1
- (2, TType.STRUCT, 'spout', (SpoutAggregateStats, SpoutAggregateStats.thrift_spec), None, ), # 2
- )
-
- def __init__(self, bolt=None, spout=None,):
- self.bolt = bolt
- self.spout = spout
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRUCT:
- self.bolt = BoltAggregateStats()
- self.bolt.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRUCT:
- self.spout = SpoutAggregateStats()
- self.spout.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('SpecificAggregateStats')
- if self.bolt is not None:
- oprot.writeFieldBegin('bolt', TType.STRUCT, 1)
- self.bolt.write(oprot)
- oprot.writeFieldEnd()
- if self.spout is not None:
- oprot.writeFieldBegin('spout', TType.STRUCT, 2)
- self.spout.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.bolt)
- value = (value * 31) ^ hash(self.spout)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class ComponentAggregateStats:
- """
- Attributes:
- - type
- - common_stats
- - specific_stats
- - last_error
- """
-
- thrift_spec = (
- None, # 0
- None, # 1
- None, # 2
- None, # 3
- None, # 4
- None, # 5
- None, # 6
- None, # 7
- None, # 8
- None, # 9
- None, # 10
- None, # 11
- None, # 12
- None, # 13
- None, # 14
- None, # 15
- None, # 16
- None, # 17
- None, # 18
- None, # 19
- None, # 20
- None, # 21
- None, # 22
- None, # 23
- None, # 24
- None, # 25
- None, # 26
- None, # 27
- None, # 28
- None, # 29
- None, # 30
- None, # 31
- None, # 32
- None, # 33
- None, # 34
- None, # 35
- None, # 36
- None, # 37
- None, # 38
- None, # 39
- None, # 40
- None, # 41
- None, # 42
- None, # 43
- None, # 44
- None, # 45
- None, # 46
- None, # 47
- None, # 48
- None, # 49
- None, # 50
- None, # 51
- None, # 52
- None, # 53
- None, # 54
- None, # 55
- None, # 56
- None, # 57
- None, # 58
- None, # 59
- None, # 60
- None, # 61
- None, # 62
- None, # 63
- None, # 64
- None, # 65
- None, # 66
- None, # 67
- None, # 68
- None, # 69
- None, # 70
- None, # 71
- None, # 72
- None, # 73
- None, # 74
- None, # 75
- None, # 76
- None, # 77
- None, # 78
- None, # 79
- None, # 80
- None, # 81
- None, # 82
- None, # 83
- None, # 84
- None, # 85
- None, # 86
- None, # 87
- None, # 88
- None, # 89
- None, # 90
- None, # 91
- None, # 92
- None, # 93
- None, # 94
- None, # 95
- None, # 96
- None, # 97
- None, # 98
- None, # 99
- None, # 100
- None, # 101
- None, # 102
- None, # 103
- None, # 104
- None, # 105
- None, # 106
- None, # 107
- None, # 108
- None, # 109
- None, # 110
- None, # 111
- None, # 112
- None, # 113
- None, # 114
- None, # 115
- None, # 116
- None, # 117
- None, # 118
- None, # 119
- None, # 120
- None, # 121
- None, # 122
- None, # 123
- None, # 124
- None, # 125
- None, # 126
- None, # 127
- None, # 128
- None, # 129
- None, # 130
- None, # 131
- None, # 132
- None, # 133
- None, # 134
- None, # 135
- None, # 136
- None, # 137
- None, # 138
- None, # 139
- None, # 140
- None, # 141
- None, # 142
- None, # 143
- None, # 144
- None, # 145
- None, # 146
- None, # 147
- None, # 148
- None, # 149
- None, # 150
- None, # 151
- None, # 152
- None, # 153
- None, # 154
- None, # 155
- None, # 156
- None, # 157
- None, # 158
- None, # 159
- None, # 160
- None, # 161
- None, # 162
- None, # 163
- None, # 164
- None, # 165
- None, # 166
- None, # 167
- None, # 168
- None, # 169
- None, # 170
- None, # 171
- None, # 172
- None, # 173
- None, # 174
- None, # 175
- None, # 176
- None, # 177
- None, # 178
- None, # 179
- None, # 180
- None, # 181
- None, # 182
- None, # 183
- None, # 184
- None, # 185
- None, # 186
- None, # 187
- None, # 188
- None, # 189
- None, # 190
- None, # 191
- None, # 192
- None, # 193
- None, # 194
- None, # 195
- None, # 196
- None, # 197
- None, # 198
- None, # 199
- None, # 200
- None, # 201
- None, # 202
- None, # 203
- None, # 204
- None, # 205
- None, # 206
- None, # 207
- None, # 208
- None, # 209
- None, # 210
- None, # 211
- None, # 212
- None, # 213
- None, # 214
- None, # 215
- None, # 216
- None, # 217
- None, # 218
- None, # 219
- None, # 220
- None, # 221
- None, # 222
- None, # 223
- None, # 224
- None, # 225
- None, # 226
- None, # 227
- None, # 228
- None, # 229
- None, # 230
- None, # 231
- None, # 232
- None, # 233
- None, # 234
- None, # 235
- None, # 236
- None, # 237
- None, # 238
- None, # 239
- None, # 240
- None, # 241
- None, # 242
- None, # 243
- None, # 244
- None, # 245
- None, # 246
- None, # 247
- None, # 248
- None, # 249
- None, # 250
- None, # 251
- None, # 252
- None, # 253
- None, # 254
- None, # 255
- None, # 256
- None, # 257
- None, # 258
- None, # 259
- None, # 260
- None, # 261
- None, # 262
- None, # 263
- None, # 264
- None, # 265
- None, # 266
- None, # 267
- None, # 268
- None, # 269
- None, # 270
- None, # 271
- None, # 272
- None, # 273
- None, # 274
- None, # 275
- None, # 276
- None, # 277
- None, # 278
- None, # 279
- None, # 280
- None, # 281
- None, # 282
- None, # 283
- None, # 284
- None, # 285
- None, # 286
- None, # 287
- None, # 288
- None, # 289
- None, # 290
- None, # 291
- None, # 292
- None, # 293
- None, # 294
- None, # 295
- None, # 296
- None, # 297
- None, # 298
- None, # 299
- None, # 300
- None, # 301
- None, # 302
- None, # 303
- None, # 304
- None, # 305
- None, # 306
- None, # 307
- None, # 308
- None, # 309
- None, # 310
- None, # 311
- None, # 312
- None, # 313
- None, # 314
- None, # 315
- None, # 316
- None, # 317
- None, # 318
- None, # 319
- None, # 320
- None, # 321
- None, # 322
- None, # 323
- None, # 324
- None, # 325
- None, # 326
- None, # 327
- None, # 328
- None, # 329
- None, # 330
- None, # 331
- None, # 332
- None, # 333
- None, # 334
- None, # 335
- None, # 336
- None, # 337
- None, # 338
- None, # 339
- None, # 340
- None, # 341
- None, # 342
- None, # 343
- None, # 344
- None, # 345
- None, # 346
- None, # 347
- None, # 348
- None, # 349
- None, # 350
- None, # 351
- None, # 352
- None, # 353
- None, # 354
- None, # 355
- None, # 356
- None, # 357
- None, # 358
- None, # 359
- None, # 360
- None, # 361
- None, # 362
- None, # 363
- None, # 364
- None, # 365
- None, # 366
- None, # 367
- None, # 368
- None, # 369
- None, # 370
- None, # 371
- None, # 372
- None, # 373
- None, # 374
- None, # 375
- None, # 376
- None, # 377
- None, # 378
- None, # 379
- None, # 380
- None, # 381
- None, # 382
- None, # 383
- None, # 384
- None, # 385
- None, # 386
- None, # 387
- None, # 388
- None, # 389
- None, # 390
- None, # 391
- None, # 392
- None, # 393
- None, # 394
- None, # 395
- None, # 396
- None, # 397
- None, # 398
- None, # 399
- None, # 400
- None, # 401
- None, # 402
- None, # 403
- None, # 404
- None, # 405
- None, # 406
- None, # 407
- None, # 408
- None, # 409
- None, # 410
- None, # 411
- None, # 412
- None, # 413
- None, # 414
- None, # 415
- None, # 416
- None, # 417
- None, # 418
- None, # 419
- None, # 420
- None, # 421
- None, # 422
- None, # 423
- None, # 424
- None, # 425
- None, # 426
- None, # 427
- None, # 428
- None, # 429
- None, # 430
- None, # 431
- None, # 432
- None, # 433
- None, # 434
- None, # 435
- None, # 436
- None, # 437
- None, # 438
- None, # 439
- None, # 440
- None, # 441
- None, # 442
- None, # 443
- None, # 444
- None, # 445
- None, # 446
- None, # 447
- None, # 448
- None, # 449
- None, # 450
- None, # 451
- None, # 452
- None, # 453
- None, # 454
- None, # 455
- None, # 456
- None, # 457
- None, # 458
- None, # 459
- None, # 460
- None, # 461
- None, # 462
- None, # 463
- None, # 464
- None, # 465
- None, # 466
- None, # 467
- None, # 468
- None, # 469
- None, # 470
- None, # 471
- None, # 472
- None, # 473
- None, # 474
- None, # 475
- None, # 476
- None, # 477
- None, # 478
- None, # 479
- None, # 480
- None, # 481
- None, # 482
- None, # 483
- None, # 484
- None, # 485
- None, # 486
- None, # 487
- None, # 488
- None, # 489
- None, # 490
- None, # 491
- None, # 492
- None, # 493
- None, # 494
- None, # 495
- None, # 496
- None, # 497
- None, # 498
- None, # 499
- None, # 500
- None, # 501
- None, # 502
- None, # 503
- None, # 504
- None, # 505
- None, # 506
- None, # 507
- None, # 508
- None, # 509
- None, # 510
- None, # 511
- None, # 512
- (513, TType.I32, 'type', None, None, ), # 513
- (514, TType.STRUCT, 'common_stats', (CommonAggregateStats, CommonAggregateStats.thrift_spec), None, ), # 514
- (515, TType.STRUCT, 'specific_stats', (SpecificAggregateStats, SpecificAggregateStats.thrift_spec), None, ), # 515
- (516, TType.STRUCT, 'last_error', (ErrorInfo, ErrorInfo.thrift_spec), None, ), # 516
- )
-
- def __init__(self, type=None, common_stats=None, specific_stats=None, last_error=None,):
- self.type = type
- self.common_stats = common_stats
- self.specific_stats = specific_stats
- self.last_error = last_error
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 513:
- if ftype == TType.I32:
- self.type = iprot.readI32();
- else:
- iprot.skip(ftype)
- elif fid == 514:
- if ftype == TType.STRUCT:
- self.common_stats = CommonAggregateStats()
- self.common_stats.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 515:
- if ftype == TType.STRUCT:
- self.specific_stats = SpecificAggregateStats()
- self.specific_stats.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 516:
- if ftype == TType.STRUCT:
- self.last_error = ErrorInfo()
- self.last_error.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('ComponentAggregateStats')
- if self.type is not None:
- oprot.writeFieldBegin('type', TType.I32, 513)
- oprot.writeI32(self.type)
- oprot.writeFieldEnd()
- if self.common_stats is not None:
- oprot.writeFieldBegin('common_stats', TType.STRUCT, 514)
- self.common_stats.write(oprot)
- oprot.writeFieldEnd()
- if self.specific_stats is not None:
- oprot.writeFieldBegin('specific_stats', TType.STRUCT, 515)
- self.specific_stats.write(oprot)
- oprot.writeFieldEnd()
- if self.last_error is not None:
- oprot.writeFieldBegin('last_error', TType.STRUCT, 516)
- self.last_error.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.type)
- value = (value * 31) ^ hash(self.common_stats)
- value = (value * 31) ^ hash(self.specific_stats)
- value = (value * 31) ^ hash(self.last_error)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class TopologyStats:
- """
- Attributes:
- - window_to_emitted
- - window_to_transferred
- - window_to_complete_latencies_ms
- - window_to_acked
- - window_to_failed
- """
-
- thrift_spec = (
- None, # 0
- None, # 1
- None, # 2
- None, # 3
- None, # 4
- None, # 5
- None, # 6
- None, # 7
- None, # 8
- None, # 9
- None, # 10
- None, # 11
- None, # 12
- None, # 13
- None, # 14
- None, # 15
- None, # 16
- None, # 17
- None, # 18
- None, # 19
- None, # 20
- None, # 21
- None, # 22
- None, # 23
- None, # 24
- None, # 25
- None, # 26
- None, # 27
- None, # 28
- None, # 29
- None, # 30
- None, # 31
- None, # 32
- None, # 33
- None, # 34
- None, # 35
- None, # 36
- None, # 37
- None, # 38
- None, # 39
- None, # 40
- None, # 41
- None, # 42
- None, # 43
- None, # 44
- None, # 45
- None, # 46
- None, # 47
- None, # 48
- None, # 49
- None, # 50
- None, # 51
- None, # 52
- None, # 53
- None, # 54
- None, # 55
- None, # 56
- None, # 57
- None, # 58
- None, # 59
- None, # 60
- None, # 61
- None, # 62
- None, # 63
- None, # 64
- None, # 65
- None, # 66
- None, # 67
- None, # 68
- None, # 69
- None, # 70
- None, # 71
- None, # 72
- None, # 73
- None, # 74
- None, # 75
- None, # 76
- None, # 77
- None, # 78
- None, # 79
- None, # 80
- None, # 81
- None, # 82
- None, # 83
- None, # 84
- None, # 85
- None, # 86
- None, # 87
- None, # 88
- None, # 89
- None, # 90
- None, # 91
- None, # 92
- None, # 93
- None, # 94
- None, # 95
- None, # 96
- None, # 97
- None, # 98
- None, # 99
- None, # 100
- None, # 101
- None, # 102
- None, # 103
- None, # 104
- None, # 105
- None, # 106
- None, # 107
- None, # 108
- None, # 109
- None, # 110
- None, # 111
- None, # 112
- None, # 113
- None, # 114
- None, # 115
- None, # 116
- None, # 117
- None, # 118
- None, # 119
- None, # 120
- None, # 121
- None, # 122
- None, # 123
- None, # 124
- None, # 125
- None, # 126
- None, # 127
- None, # 128
- None, # 129
- None, # 130
- None, # 131
- None, # 132
- None, # 133
- None, # 134
- None, # 135
- None, # 136
- None, # 137
- None, # 138
- None, # 139
- None, # 140
- None, # 141
- None, # 142
- None, # 143
- None, # 144
- None, # 145
- None, # 146
- None, # 147
- None, # 148
- None, # 149
- None, # 150
- None, # 151
- None, # 152
- None, # 153
- None, # 154
- None, # 155
- None, # 156
- None, # 157
- None, # 158
- None, # 159
- None, # 160
- None, # 161
- None, # 162
- None, # 163
- None, # 164
- None, # 165
- None, # 166
- None, # 167
- None, # 168
- None, # 169
- None, # 170
- None, # 171
- None, # 172
- None, # 173
- None, # 174
- None, # 175
- None, # 176
- None, # 177
- None, # 178
- None, # 179
- None, # 180
- None, # 181
- None, # 182
- None, # 183
- None, # 184
- None, # 185
- None, # 186
- None, # 187
- None, # 188
- None, # 189
- None, # 190
- None, # 191
- None, # 192
- None, # 193
- None, # 194
- None, # 195
- None, # 196
- None, # 197
- None, # 198
- None, # 199
- None, # 200
- None, # 201
- None, # 202
- None, # 203
- None, # 204
- None, # 205
- None, # 206
- None, # 207
- None, # 208
- None, # 209
- None, # 210
- None, # 211
- None, # 212
- None, # 213
- None, # 214
- None, # 215
- None, # 216
- None, # 217
- None, # 218
- None, # 219
- None, # 220
- None, # 221
- None, # 222
- None, # 223
- None, # 224
- None, # 225
- None, # 226
- None, # 227
- None, # 228
- None, # 229
- None, # 230
- None, # 231
- None, # 232
- None, # 233
- None, # 234
- None, # 235
- None, # 236
- None, # 237
- None, # 238
- None, # 239
- None, # 240
- None, # 241
- None, # 242
- None, # 243
- None, # 244
- None, # 245
- None, # 246
- None, # 247
- None, # 248
- None, # 249
- None, # 250
- None, # 251
- None, # 252
- None, # 253
- None, # 254
- None, # 255
- None, # 256
- None, # 257
- None, # 258
- None, # 259
- None, # 260
- None, # 261
- None, # 262
- None, # 263
- None, # 264
- None, # 265
- None, # 266
- None, # 267
- None, # 268
- None, # 269
- None, # 270
- None, # 271
- None, # 272
- None, # 273
- None, # 274
- None, # 275
- None, # 276
- None, # 277
- None, # 278
- None, # 279
- None, # 280
- None, # 281
- None, # 282
- None, # 283
- None, # 284
- None, # 285
- None, # 286
- None, # 287
- None, # 288
- None, # 289
- None, # 290
- None, # 291
- None, # 292
- None, # 293
- None, # 294
- None, # 295
- None, # 296
- None, # 297
- None, # 298
- None, # 299
- None, # 300
- None, # 301
- None, # 302
- None, # 303
- None, # 304
- None, # 305
- None, # 306
- None, # 307
- None, # 308
- None, # 309
- None, # 310
- None, # 311
- None, # 312
- None, # 313
- None, # 314
- None, # 315
- None, # 316
- None, # 317
- None, # 318
- None, # 319
- None, # 320
- None, # 321
- None, # 322
- None, # 323
- None, # 324
- None, # 325
- None, # 326
- None, # 327
- None, # 328
- None, # 329
- None, # 330
- None, # 331
- None, # 332
- None, # 333
- None, # 334
- None, # 335
- None, # 336
- None, # 337
- None, # 338
- None, # 339
- None, # 340
- None, # 341
- None, # 342
- None, # 343
- None, # 344
- None, # 345
- None, # 346
- None, # 347
- None, # 348
- None, # 349
- None, # 350
- None, # 351
- None, # 352
- None, # 353
- None, # 354
- None, # 355
- None, # 356
- None, # 357
- None, # 358
- None, # 359
- None, # 360
- None, # 361
- None, # 362
- None, # 363
- None, # 364
- None, # 365
- None, # 366
- None, # 367
- None, # 368
- None, # 369
- None, # 370
- None, # 371
- None, # 372
- None, # 373
- None, # 374
- None, # 375
- None, # 376
- None, # 377
- None, # 378
- None, # 379
- None, # 380
- None, # 381
- None, # 382
- None, # 383
- None, # 384
- None, # 385
- None, # 386
- None, # 387
- None, # 388
- None, # 389
- None, # 390
- None, # 391
- None, # 392
- None, # 393
- None, # 394
- None, # 395
- None, # 396
- None, # 397
- None, # 398
- None, # 399
- None, # 400
- None, # 401
- None, # 402
- None, # 403
- None, # 404
- None, # 405
- None, # 406
- None, # 407
- None, # 408
- None, # 409
- None, # 410
- None, # 411
- None, # 412
- None, # 413
- None, # 414
- None, # 415
- None, # 416
- None, # 417
- None, # 418
- None, # 419
- None, # 420
- None, # 421
- None, # 422
- None, # 423
- None, # 424
- None, # 425
- None, # 426
- None, # 427
- None, # 428
- None, # 429
- None, # 430
- None, # 431
- None, # 432
- None, # 433
- None, # 434
- None, # 435
- None, # 436
- None, # 437
- None, # 438
- None, # 439
- None, # 440
- None, # 441
- None, # 442
- None, # 443
- None, # 444
- None, # 445
- None, # 446
- None, # 447
- None, # 448
- None, # 449
- None, # 450
- None, # 451
- None, # 452
- None, # 453
- None, # 454
- None, # 455
- None, # 456
- None, # 457
- None, # 458
- None, # 459
- None, # 460
- None, # 461
- None, # 462
- None, # 463
- None, # 464
- None, # 465
- None, # 466
- None, # 467
- None, # 468
- None, # 469
- None, # 470
- None, # 471
- None, # 472
- None, # 473
- None, # 474
- None, # 475
- None, # 476
- None, # 477
- None, # 478
- None, # 479
- None, # 480
- None, # 481
- None, # 482
- None, # 483
- None, # 484
- None, # 485
- None, # 486
- None, # 487
- None, # 488
- None, # 489
- None, # 490
- None, # 491
- None, # 492
- None, # 493
- None, # 494
- None, # 495
- None, # 496
- None, # 497
- None, # 498
- None, # 499
- None, # 500
- None, # 501
- None, # 502
- None, # 503
- None, # 504
- None, # 505
- None, # 506
- None, # 507
- None, # 508
- None, # 509
- None, # 510
- None, # 511
- None, # 512
- (513, TType.MAP, 'window_to_emitted', (TType.STRING,None,TType.I64,None), None, ), # 513
- (514, TType.MAP, 'window_to_transferred', (TType.STRING,None,TType.I64,None), None, ), # 514
- (515, TType.MAP, 'window_to_complete_latencies_ms', (TType.STRING,None,TType.DOUBLE,None), None, ), # 515
- (516, TType.MAP, 'window_to_acked', (TType.STRING,None,TType.I64,None), None, ), # 516
- (517, TType.MAP, 'window_to_failed', (TType.STRING,None,TType.I64,None), None, ), # 517
- )
-
- def __init__(self, window_to_emitted=None, window_to_transferred=None, window_to_complete_latencies_ms=None, window_to_acked=None, window_to_failed=None,):
- self.window_to_emitted = window_to_emitted
- self.window_to_transferred = window_to_transferred
- self.window_to_complete_latencies_ms = window_to_complete_latencies_ms
- self.window_to_acked = window_to_acked
- self.window_to_failed = window_to_failed
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 513:
- if ftype == TType.MAP:
- self.window_to_emitted = {}
- (_ktype284, _vtype285, _size283 ) = iprot.readMapBegin()
- for _i287 in xrange(_size283):
- _key288 = iprot.readString().decode('utf-8')
- _val289 = iprot.readI64();
- self.window_to_emitted[_key288] = _val289
- iprot.readMapEnd()
- else:
- iprot.skip(ftype)
- elif fid == 514:
- if ftype == TType.MAP:
- self.window_to_transferred = {}
- (_ktype291, _vtype292, _size290 ) = iprot.readMapBegin()
- for _i294 in xrange(_size290):
- _key295 = iprot.readString().decode('utf-8')
- _val296 = iprot.readI64();
- self.window_to_transferred[_key295] = _val296
- iprot.readMapEnd()
- else:
- iprot.skip(ftype)
- elif fid == 515:
- if ftype == TType.MAP:
- self.window_to_complete_latencies_ms = {}
- (_ktype298, _vtype299, _size297 ) = iprot.readMapBegin()
- for _i301 in xrange(_size297):
- _key302 = iprot.readString().decode('utf-8')
- _val303 = iprot.readDouble();
- self.window_to_complete_latencies_ms[_key302] = _val303
- iprot.readMapEnd()
- else:
- iprot.skip(ftype)
- elif fid == 516:
- if ftype == TType.MAP:
- self.window_to_acked = {}
- (_ktype305, _vtype306, _size304 ) = iprot.readMapBegin()
- for _i308 in xrange(_size304):
- _key309 = iprot.readString().decode('utf-8')
- _val310 = iprot.readI64();
- self.window_to_acked[_key309] = _val310
- iprot.readMapEnd()
- else:
- iprot.skip(ftype)
- elif fid == 517:
- if ftype == TType.MAP:
- self.window_to_failed = {}
- (_ktype312, _vtype313, _size311 ) = iprot.readMapBegin()
- for _i315 in xrange(_size311):
- _key316 = iprot.readString().decode('utf-8')
- _val317 = iprot.readI64();
- self.window_to_failed[_key316] = _val317
- iprot.readMapEnd()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('TopologyStats')
- if self.window_to_emitted is not None:
- oprot.writeFieldBegin('window_to_emitted', TType.MAP, 513)
- oprot.writeMapBegin(TType.STRING, TType.I64, len(self.window_to_emitted))
- for kiter318,viter319 in self.window_to_emitted.items():
- oprot.writeString(kiter318.encode('utf-8'))
- oprot.writeI64(viter319)
- oprot.writeMapEnd()
- oprot.writeFieldEnd()
- if self.window_to_transferred is not None:
- oprot.writeFieldBegin('window_to_transferred', TType.MAP, 514)
- oprot.writeMapBegin(TType.STRING, TType.I64, len(self.window_to_transferred))
- for kiter320,viter321 in self.window_to_transferred.items():
- oprot.writeString(kiter320.encode('utf-8'))
- oprot.writeI64(viter321)
- oprot.writeMapEnd()
- oprot.writeFieldEnd()
- if self.window_to_complete_latencies_ms is not None:
- oprot.writeFieldBegin('window_to_complete_latencies_ms', TType.MAP, 515)
- oprot.writeMapBegin(TType.STRING, TType.DOUBLE, len(self.window_to_complete_latencies_ms))
- for kiter322,viter323 in self.window_to_complete_latencies_ms.items():
- oprot.writeString(kiter322.encode('utf-8'))
- oprot.writeDouble(viter323)
- oprot.writeMapEnd()
- oprot.writeFieldEnd()
- if self.window_to_acked is not None:
- oprot.writeFieldBegin('window_to_acked', TType.MAP, 516)
- oprot.writeMapBegin(TType.STRING, TType.I64, len(self.window_to_acked))
- for kiter324,viter325 in self.window_to_acked.items():
- oprot.writeString(kiter324.encode('utf-8'))
- oprot.writeI64(viter325)
- oprot.writeMapEnd()
- oprot.writeFieldEnd()
- if self.window_to_failed is not None:
- oprot.writeFieldBegin('window_to_failed', TType.MAP, 517)
- oprot.writeMapBegin(TType.STRING, TType.I64, len(self.window_to_failed))
- for kiter326,viter327 in self.window_to_failed.items():
- oprot.writeString(kiter326.encode('utf-8'))
- oprot.writeI64(viter327)
- oprot.writeMapEnd()
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.window_to_emitted)
- value = (value * 31) ^ hash(self.window_to_transferred)
- value = (value * 31) ^ hash(self.window_to_complete_latencies_ms)
- value = (value * 31) ^ hash(self.window_to_acked)
- value = (value * 31) ^ hash(self.window_to_failed)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class TopologyPageInfo:
- """
- Attributes:
- - id
- - name
- - uptime_secs
- - status
- - num_tasks
- - num_workers
- - num_executors
- - topology_conf
- - id_to_spout_agg_stats
- - id_to_bolt_agg_stats
- - sched_status
- - topology_stats
- - owner
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'id', None, None, ), # 1
- None, # 2
- None, # 3
- None, # 4
- None, # 5
- None, # 6
- None, # 7
- None, # 8
- None, # 9
- None, # 10
- None, # 11
- None, # 12
- None, # 13
- None, # 14
- None, # 15
- None, # 16
- None, # 17
- None, # 18
- None, # 19
- None, # 20
- None, # 21
- None, # 22
- None, # 23
- None, # 24
- None, # 25
- None, # 26
- None, # 27
- None, # 28
- None, # 29
- None, # 30
- None, # 31
- None, # 32
- None, # 33
- None, # 34
- None, # 35
- None, # 36
- None, # 37
- None, # 38
- None, # 39
- None, # 40
- None, # 41
- None, # 42
- None, # 43
- None, # 44
- None, # 45
- None, # 46
- None, # 47
- None, # 48
- None, # 49
- None, # 50
- None, # 51
- None, # 52
- None, # 53
- None, # 54
- None, # 55
- None, # 56
- None, # 57
- None, # 58
- None, # 59
- None, # 60
- None, # 61
- None, # 62
- None, # 63
- None, # 64
- None, # 65
- None, # 66
- None, # 67
- None, # 68
- None, # 69
- None, # 70
- None, # 71
- None, # 72
- None, # 73
- None, # 74
- None, # 75
- None, # 76
- None, # 77
- None, # 78
- None, # 79
- None, # 80
- None, # 81
- None, # 82
- None, # 83
- None, # 84
- None, # 85
- None, # 86
- None, # 87
- None, # 88
- None, # 89
- None, # 90
- None, # 91
- None, # 92
- None, # 93
- None, # 94
- None, # 95
- None, # 96
- None, # 97
- None, # 98
- None, # 99
- None, # 100
- None, # 101
- None, # 102
- None, # 103
- None, # 104
- None, # 105
- None, # 106
- None, # 107
- None, # 108
- None, # 109
- None, # 110
- None, # 111
- None, # 112
- None, # 113
- None, # 114
- None, # 115
- None, # 116
- None, # 117
- None, # 118
- None, # 119
- None, # 120
- None, # 121
- None, # 122
- None, # 123
- None, # 124
- None, # 125
- None, # 126
- None, # 127
- None, # 128
- None, # 129
- None, # 130
- None, # 131
- None, # 132
- None, # 133
- None, # 134
- None, # 135
- None, # 136
- None, # 137
- None, # 138
- None, # 139
- None, # 140
- None, # 141
- None, # 142
- None, # 143
- None, # 144
- None, # 145
- None, # 146
- None, # 147
- None, # 148
- None, # 149
- None, # 150
- None, # 151
- None, # 152
- None, # 153
- None, # 154
- None, # 155
- None, # 156
- None, # 157
- None, # 158
- None, # 159
- None, # 160
- None, # 161
- None, # 162
- None, # 163
- None, # 164
- None, # 165
- None, # 166
- None, # 167
- None, # 168
- None, # 169
- None, # 170
- None, # 171
- None, # 172
- None, # 173
- None, # 174
- None, # 175
- None, # 176
- None, # 177
- None, # 178
- None, # 179
- None, # 180
- None, # 181
- None, # 182
- None, # 183
- None, # 184
- None, # 185
- None, # 186
- None, # 187
- None, # 188
- None, # 189
- None, # 190
- None, # 191
- None, # 192
- None, # 193
- None, # 194
- None, # 195
- None, # 196
- None, # 197
- None, # 198
- None, # 199
- None, # 200
- None, # 201
- None, # 202
- None, # 203
- None, # 204
- None, # 205
- None, # 206
- None, # 207
- None, # 208
- None, # 209
- None, # 210
- None, # 211
- None, # 212
- None, # 213
- None, # 214
- None, # 215
- None, # 216
- None, # 217
- None, # 218
- None, # 219
- None, # 220
- None, # 221
- None, # 222
- None, # 223
- None, # 224
- None, # 225
- None, # 226
- None, # 227
- None, # 228
- None, # 229
- None, # 230
- None, # 231
- None, # 232
- None, # 233
- None, # 234
- None, # 235
- None, # 236
- None, # 237
- None, # 238
- None, # 239
- None, # 240
- None, # 241
- None, # 242
- None, # 243
- None, # 244
- None, # 245
- None, # 246
- None, # 247
- None, # 248
- None, # 249
- None, # 250
- None, # 251
- None, # 252
- None, # 253
- None, # 254
- None, # 255
- None, # 256
- None, # 257
- None, # 258
- None, # 259
- None, # 260
- None, # 261
- None, # 262
- None, # 263
- None, # 264
- None, # 265
- None, # 266
- None, # 267
- None, # 268
- None, # 269
- None, # 270
- None, # 271
- None, # 272
- None, # 273
- None, # 274
- None, # 275
- None, # 276
- None, # 277
- None, # 278
- None, # 279
- None, # 280
- None, # 281
- None, # 282
- None, # 283
- None, # 284
- None, # 285
- None, # 286
- None, # 287
- None, # 288
- None, # 289
- None, # 290
- None, # 291
- None, # 292
- None, # 293
- None, # 294
- None, # 295
- None, # 296
- None, # 297
- None, # 298
- None, # 299
- None, # 300
- None, # 301
- None, # 302
- None, # 303
- None, # 304
- None, # 305
- None, # 306
- None, # 307
- None, # 308
- None, # 309
- None, # 310
- None, # 311
- None, # 312
- None, # 313
- None, # 314
- None, # 315
- None, # 316
- None, # 317
- None, # 318
- None, # 319
- None, # 320
- None, # 321
- None, # 322
- None, # 323
- None, # 324
- None, # 325
- None, # 326
- None, # 327
- None, # 328
- None, # 329
- None, # 330
- None, # 331
- None, # 332
- None, # 333
- None, # 334
- None, # 335
- None, # 336
- None, # 337
- None, # 338
- None, # 339
- None, # 340
- None, # 341
- None, # 342
- None, # 343
- None, # 344
- None, # 345
- None, # 346
- None, # 347
- None, # 348
- None, # 349
- None, # 350
- None, # 351
- None, # 352
- None, # 353
- None, # 354
- None, # 355
- None, # 356
- None, # 357
- None, # 358
- None, # 359
- None, # 360
- None, # 361
- None, # 362
- None, # 363
- None, # 364
- None, # 365
- None, # 366
- None, # 367
- None, # 368
- None, # 369
- None, # 370
- None, # 371
- None, # 372
- None, # 373
- None, # 374
- None, # 375
- None, # 376
- None, # 377
- None, # 378
- None, # 379
- None, # 380
- None, # 381
- None, # 382
- None, # 383
- None, # 384
- None, # 385
- None, # 386
- None, # 387
- None, # 388
- None, # 389
- None, # 390
- None, # 391
- None, # 392
- None, # 393
- None, # 394
- None, # 395
- None, # 396
- None, # 397
- None, # 398
- None, # 399
- None, # 400
- None, # 401
- None, # 402
- None, # 403
- None, # 404
- None, # 405
- None, # 406
- None, # 407
- None, # 408
- None, # 409
- None, # 410
- None, # 411
- None, # 412
- None, # 413
- None, # 414
- None, # 415
- None, # 416
- None, # 417
- None, # 418
- None, # 419
- None, # 420
- None, # 421
- None, # 422
- None, # 423
- None, # 424
- None, # 425
- None, # 426
- None, # 427
- None, # 428
- None, # 429
- None, # 430
- None, # 431
- None, # 432
- None, # 433
- None, # 434
- None, # 435
- None, # 436
- None, # 437
- None, # 438
- None, # 439
- None, # 440
- None, # 441
- None, # 442
- None, # 443
- None, # 444
- None, # 445
- None, # 446
- None, # 447
- None, # 448
- None, # 449
- None, # 450
- None, # 451
- None, # 452
- None, # 453
- None, # 454
- None, # 455
- None, # 456
- None, # 457
- None, # 458
- None, # 459
- None, # 460
- None, # 461
- None, # 462
- None, # 463
- None, # 464
- None, # 465
- None, # 466
- None, # 467
- None, # 468
- None, # 469
- None, # 470
- None, # 471
- None, # 472
- None, # 473
- None, # 474
- None, # 475
- None, # 476
- None, # 477
- None, # 478
- None, # 479
- None, # 480
- None, # 481
- None, # 482
- None, # 483
- None, # 484
- None, # 485
- None, # 486
- None, # 487
- None, # 488
- None, # 489
- None, # 490
- None, # 491
- None, # 492
- None, # 493
- None, # 494
- None, # 495
- None, # 496
- None, # 497
- None, # 498
- None, # 499
- None, # 500
- None, # 501
- None, # 502
- None, # 503
- None, # 504
- None, # 505
- None, # 506
- None, # 507
- None, # 508
- None, # 509
- None, # 510
- None, # 511
- None, # 512
- (513, TType.STRING, 'name', None, None, ), # 513
- (514, TType.I32, 'uptime_secs', None, None, ), # 514
- (515, TType.STRING, 'status', None, None, ), # 515
- (516, TType.I32, 'num_tasks', None, None, ), # 516
- (517, TType.I32, 'num_workers', None, None, ), # 517
- (518, TType.I32, 'num_executors', None, None, ), # 518
- (519, TType.STRING, 'topology_conf', None, None, ), # 519
- (520, TType.MAP, 'id_to_spout_agg_stats', (TType.STRING,None,TType.STRUCT,(ComponentAggregateStats, ComponentAggregateStats.thrift_spec)), None, ), # 520
- (521, TType.MAP, 'id_to_bolt_agg_stats', (TType.STRING,None,TType.STRUCT,(ComponentAggregateStats, ComponentAggregateStats.thrift_spec)), None, ), # 521
- (522, TType.STRING, 'sched_status', None, None, ), # 522
- (523, TType.STRUCT, 'topology_stats', (TopologyStats, TopologyStats.thrift_spec), None, ), # 523
- (524, TType.STRING, 'owner', None, None, ), # 524
- )
-
- def __init__(self, id=None, name=None, uptime_secs=None, status=None, num_tasks=None, num_workers=None, num_executors=None, topology_conf=None, id_to_spout_agg_stats=None, id_to_bolt_agg_stats=None, sched_status=None, topology_stats=None, owner=None,):
- self.id = id
- self.name = name
- self.uptime_secs = uptime_secs
- self.status = status
- self.num_tasks = num_tasks
- self.num_workers = num_workers
- self.num_executors = num_executors
- self.topology_conf = topology_conf
- self.id_to_spout_agg_stats = id_to_spout_agg_stats
- self.id_to_bolt_agg_stats = id_to_bolt_agg_stats
- self.sched_status = sched_status
- self.topology_stats = topology_stats
- self.owner = owner
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.id = iprot.readString().decode('utf-8')
- else:
- iprot.skip(ftype)
- elif fid == 513:
- if ftype == TType.STRING:
- self.name = iprot.readString().decode('utf-8')
- else:
- iprot.skip(ftype)
- elif fid == 514:
- if ftype == TType.I32:
- self.uptime_secs = iprot.readI32();
- else:
- iprot.skip(ftype)
- elif fid == 515:
- if ftype == TType.STRING:
- self.status = iprot.readString().decode('utf-8')
- else:
- iprot.skip(ftype)
- elif fid == 516:
- if ftype == TType.I32:
- self.num_tasks = iprot.readI32();
- else:
- iprot.skip(ftype)
- elif fid == 517:
- if ftype == TType.I32:
- self.num_workers = iprot.readI32();
- else:
- iprot.skip(ftype)
- elif fid == 518:
- if ftype == TType.I32:
- self.num_executors = iprot.readI32();
- else:
- iprot.skip(ftype)
- elif fid == 519:
- if ftype == TType.STRING:
- self.topology_conf = iprot.readString().decode('utf-8')
- else:
- iprot.skip(ftype)
- elif fid == 520:
- if ftype == TType.MAP:
- self.id_to_spout_agg_stats = {}
- (_ktype329, _vtype330, _size328 ) = iprot.readMapBegin()
- for _i332 in xrange(_size328):
- _key333 = iprot.readString().decode('utf-8')
- _val334 = ComponentAggregateStats()
- _val334.read(iprot)
- self.id_to_spout_agg_stats[_key333] = _val334
- iprot.readMapEnd()
- else:
- iprot.skip(ftype)
- elif fid == 521:
- if ftype == TType.MAP:
- self.id_to_bolt_agg_stats = {}
- (_ktype336, _vtype337, _size335 ) = iprot.readMapBegin()
- for _i339 in xrange(_size335):
- _key340 = iprot.readString().decode('utf-8')
- _val341 = ComponentAggregateStats()
- _val341.read(iprot)
- self.id_to_bolt_agg_stats[_key340] = _val341
- iprot.readMapEnd()
- else:
- iprot.skip(ftype)
- elif fid == 522:
- if ftype == TType.STRING:
- self.sched_status = iprot.readString().decode('utf-8')
- else:
- iprot.skip(ftype)
- elif fid == 523:
- if ftype == TType.STRUCT:
- self.topology_stats = TopologyStats()
- self.topology_stats.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 524:
- if ftype == TType.STRING:
- self.owner = iprot.readString().decode('utf-8')
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('TopologyPageInfo')
- if self.id is not None:
- oprot.writeFieldBegin('id', TType.STRING, 1)
- oprot.writeString(self.id.encode('utf-8'))
- oprot.writeFieldEnd()
- if self.name is not None:
- oprot.writeFieldBegin('name', TType.STRING, 513)
- oprot.writeString(self.name.encode('utf-8'))
- oprot.writeFieldEnd()
- if self.uptime_secs is not None:
- oprot.writeFieldBegin('uptime_secs', TType.I32, 514)
- oprot.writeI32(self.uptime_secs)
- oprot.writeFieldEnd()
- if self.status is not None:
- oprot.writeFieldBegin('status', TType.STRING, 515)
- oprot.writeString(self.status.encode('utf-8'))
- oprot.writeFieldEnd()
- if self.num_tasks is not None:
- oprot.writeFieldBegin('num_tasks', TType.I32, 516)
- oprot.writeI32(self.num_tasks)
- oprot.writeFieldEnd()
- if self.num_workers is not None:
- oprot.writeFieldBegin('num_workers', TType.I32, 517)
- oprot.writeI32(self.num_workers)
- oprot.writeFieldEnd()
- if self.num_executors is not None:
- oprot.writeFieldBegin('num_executors', TType.I32, 518)
- oprot.writeI32(self.num_executors)
- oprot.writeFieldEnd()
- if self.topology_conf is not None:
- oprot.writeFieldBegin('topology_conf', TType.STRING, 519)
- oprot.writeString(self.topology_conf.encode('utf-8'))
- oprot.writeFieldEnd()
- if self.id_to_spout_agg_stats is not None:
- oprot.writeFieldBegin('id_to_spout_agg_stats', TType.MAP, 520)
- oprot.writeMapBegin(TType.STRING, TType.STRUCT, len(self.id_to_spout_agg_stats))
- for kiter342,viter343 in self.id_to_spout_agg_stats.items():
- oprot.writeString(kiter342.encode('utf-8'))
- viter343.write(oprot)
- oprot.writeMapEnd()
- oprot.writeFieldEnd()
- if self.id_to_bolt_agg_stats is not None:
- oprot.writeFieldBegin('id_to_bolt_agg_stats', TType.MAP, 521)
- oprot.writeMapBegin(TType.STRING, TType.STRUCT, len(self.id_to_bolt_agg_stats))
- for kiter344,viter345 in self.id_to_bolt_agg_stats.items():
- oprot.writeString(kiter344.encode('utf-8'))
- viter345.write(oprot)
- oprot.writeMapEnd()
- oprot.writeFieldEnd()
- if self.sched_status is not None:
- oprot.writeFieldBegin('sched_status', TType.STRING, 522)
- oprot.writeString(self.sched_status.encode('utf-8'))
- oprot.writeFieldEnd()
- if self.topology_stats is not None:
- oprot.writeFieldBegin('topology_stats', TType.STRUCT, 523)
- self.topology_stats.write(oprot)
- oprot.writeFieldEnd()
- if self.owner is not None:
- oprot.writeFieldBegin('owner', TType.STRING, 524)
- oprot.writeString(self.owner.encode('utf-8'))
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.id is None:
- raise TProtocol.TProtocolException(message='Required field id is unset!')
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.id)
- value = (value * 31) ^ hash(self.name)
- value = (value * 31) ^ hash(self.uptime_secs)
- value = (value * 31) ^ hash(self.status)
- value = (value * 31) ^ hash(self.num_tasks)
- value = (value * 31) ^ hash(self.num_workers)
- value = (value * 31) ^ hash(self.num_executors)
- value = (value * 31) ^ hash(self.topology_conf)
- value = (value * 31) ^ hash(self.id_to_spout_agg_stats)
- value = (value * 31) ^ hash(self.id_to_bolt_agg_stats)
- value = (value * 31) ^ hash(self.sched_status)
- value = (value * 31) ^ hash(self.topology_stats)
- value = (value * 31) ^ hash(self.owner)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class ExecutorAggregateStats:
- """
- Attributes:
- - exec_summary
- - stats
- """
-
- thrift_spec = (
- None, # 0
- None, # 1
- None, # 2
- None, # 3
- None, # 4
- None, # 5
- None, # 6
- None, # 7
- None, # 8
- None, # 9
- None, # 10
- None, # 11
- None, # 12
- None, # 13
- None, # 14
- None, # 15
- None, # 16
- None, # 17
- None, # 18
- None, # 19
- None, # 20
- None, # 21
- None, # 22
- None, # 23
- None, # 24
- None, # 25
- None, # 26
- None, # 27
- None, # 28
- None, # 29
- None, # 30
- None, # 31
- None, # 32
- None, # 33
- None, # 34
- None, # 35
- None, # 36
- None, # 37
- None, # 38
- None, # 39
- None, # 40
- None, # 41
- None, # 42
- None, # 43
- None, # 44
- None, # 45
- None, # 46
- None, # 47
- None, # 48
- None, # 49
- None, # 50
- None, # 51
- None, # 52
- None, # 53
- None, # 54
- None, # 55
- None, # 56
- None, # 57
- None, # 58
- None, # 59
- None, # 60
- None, # 61
- None, # 62
- None, # 63
- None, # 64
- None, # 65
- None, # 66
- None, # 67
- None, # 68
- None, # 69
- None, # 70
- None, # 71
- None, # 72
- None, # 73
- None, # 74
- None, # 75
- None, # 76
- None, # 77
- None, # 78
- None, # 79
- None, # 80
- None, # 81
- None, # 82
- None, # 83
- None, # 84
- None, # 85
- None, # 86
- None, # 87
- None, # 88
- None, # 89
- None, # 90
- None, # 91
- None, # 92
- None, # 93
- None, # 94
- None, # 95
- None, # 96
- None, # 97
- None, # 98
- None, # 99
- None, # 100
- None, # 101
- None, # 102
- None, # 103
- None, # 104
- None, # 105
- None, # 106
- None, # 107
- None, # 108
- None, # 109
- None, # 110
- None, # 111
- None, # 112
- None, # 113
- None, # 114
- None, # 115
- None, # 116
- None, # 117
- None, # 118
- None, # 119
- None, # 120
- None, # 121
- None, # 122
- None, # 123
- None, # 124
- None, # 125
- None, # 126
- None, # 127
- None, # 128
- None, # 129
- None, # 130
- None, # 131
- None, # 132
- None, # 133
- None, # 134
- None, # 135
- None, # 136
- None, # 137
- None, # 138
- None, # 139
- None, # 140
- None, # 141
- None, # 142
- None, # 143
- None, # 144
- None, # 145
- None, # 146
- None, # 147
- None, # 148
- None, # 149
- None, # 150
- None, # 151
- None, # 152
- None, # 153
- None, # 154
- None, # 155
- None, # 156
- None, # 157
- None, # 158
- None, # 159
- None, # 160
- None, # 161
- None, # 162
- None, # 163
- None, # 164
- None, # 165
- None, # 166
- None, # 167
- None, # 168
- None, # 169
- None, # 170
- None, # 171
- None, # 172
- None, # 173
- None, # 174
- None, # 175
- None, # 176
- None, # 177
- None, # 178
- None, # 179
- None, # 180
- None, # 181
- None, # 182
- None, # 183
- None, # 184
- None, # 185
- None, # 186
- None, # 187
- None, # 188
- None, # 189
- None, # 190
- None, # 191
- None, # 192
- None, # 193
- None, # 194
- None, # 195
- None, # 196
- None, # 197
- None, # 198
- None, # 199
- None, # 200
- None, # 201
- None, # 202
- None, # 203
- None, # 204
- None, # 205
- None, # 206
- None, # 207
- None, # 208
- None, # 209
- None, # 210
- None, # 211
- None, # 212
- None, # 213
- None, # 214
- None, # 215
- None, # 216
- None, # 217
- None, # 218
- None, # 219
- None, # 220
- None, # 221
- None, # 222
- None, # 223
- None, # 224
- None, # 225
- None, # 226
- None, # 227
- None, # 228
- None, # 229
- None, # 230
- None, # 231
- None, # 232
- None, # 233
- None, # 234
- None, # 235
- None, # 236
- None, # 237
- None, # 238
- None, # 239
- None, # 240
- None, # 241
- None, # 242
- None, # 243
- None, # 244
- None, # 245
- None, # 246
- None, # 247
- None, # 248
- None, # 249
- None, # 250
- None, # 251
- None, # 252
- None, # 253
- None, # 254
- None, # 255
- None, # 256
- None, # 257
- None, # 258
- None, # 259
- None, # 260
- None, # 261
- None, # 262
- None, # 263
- None, # 264
- None, # 265
- None, # 266
- None, # 267
- None, # 268
- None, # 269
- None, # 270
- None, # 271
- None, # 272
- None, # 273
- None, #
<TRUNCATED>