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

Class fetchRequest_args

storm-client/src/py/storm/DistributedRPCInvocations.py:495–551  ·  view source on GitHub ↗

Attributes: - functionName

Source from the content-addressed store, hash-verified

493
494
495class fetchRequest_args(object):
496 """
497 Attributes:
498 - functionName
499
500 """
501 thrift_spec = None
502
503
504 def __init__(self, functionName = None,):
505 self.functionName = functionName
506
507 def read(self, iprot):
508 if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
509 iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
510 return
511 iprot.readStructBegin()
512 while True:
513 (fname, ftype, fid) = iprot.readFieldBegin()
514 if ftype == TType.STOP:
515 break
516 if fid == 1:
517 if ftype == TType.STRING:
518 self.functionName = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
519 else:
520 iprot.skip(ftype)
521 else:
522 iprot.skip(ftype)
523 iprot.readFieldEnd()
524 iprot.readStructEnd()
525
526 def write(self, oprot):
527 self.validate()
528 if oprot._fast_encode is not None and self.thrift_spec is not None:
529 oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
530 return
531 oprot.writeStructBegin('fetchRequest_args')
532 if self.functionName is not None:
533 oprot.writeFieldBegin('functionName', TType.STRING, 1)
534 oprot.writeString(self.functionName.encode('utf-8') if sys.version_info[0] == 2 else self.functionName)
535 oprot.writeFieldEnd()
536 oprot.writeFieldStop()
537 oprot.writeStructEnd()
538
539 def validate(self):
540 return
541
542 def __repr__(self):
543 L = ['%s=%r' % (key, value)
544 for key, value in self.__dict__.items()]
545 return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
546
547 def __eq__(self, other):
548 return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
549
550 def __ne__(self, other):
551 return not (self == other)
552all_structs.append(fetchRequest_args)

Callers 2

send_fetchRequestMethod · 0.70
process_fetchRequestMethod · 0.70

Calls

no outgoing calls

Tested by

no test coverage detected