MCPcopy Create free account
hub / github.com/apache/storm / getLocalAssignmentForStorm_args

Class getLocalAssignmentForStorm_args

storm-client/src/py/storm/Supervisor.py:428–484  ·  view source on GitHub ↗

Attributes: - id

Source from the content-addressed store, hash-verified

426
427
428class getLocalAssignmentForStorm_args(object):
429 """
430 Attributes:
431 - id
432
433 """
434 thrift_spec = None
435
436
437 def __init__(self, id = None,):
438 self.id = id
439
440 def read(self, iprot):
441 if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
442 iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
443 return
444 iprot.readStructBegin()
445 while True:
446 (fname, ftype, fid) = iprot.readFieldBegin()
447 if ftype == TType.STOP:
448 break
449 if fid == 1:
450 if ftype == TType.STRING:
451 self.id = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
452 else:
453 iprot.skip(ftype)
454 else:
455 iprot.skip(ftype)
456 iprot.readFieldEnd()
457 iprot.readStructEnd()
458
459 def write(self, oprot):
460 self.validate()
461 if oprot._fast_encode is not None and self.thrift_spec is not None:
462 oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
463 return
464 oprot.writeStructBegin('getLocalAssignmentForStorm_args')
465 if self.id is not None:
466 oprot.writeFieldBegin('id', TType.STRING, 1)
467 oprot.writeString(self.id.encode('utf-8') if sys.version_info[0] == 2 else self.id)
468 oprot.writeFieldEnd()
469 oprot.writeFieldStop()
470 oprot.writeStructEnd()
471
472 def validate(self):
473 return
474
475 def __repr__(self):
476 L = ['%s=%r' % (key, value)
477 for key, value in self.__dict__.items()]
478 return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
479
480 def __eq__(self, other):
481 return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
482
483 def __ne__(self, other):
484 return not (self == other)
485all_structs.append(getLocalAssignmentForStorm_args)

Calls

no outgoing calls

Tested by

no test coverage detected