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

Method write

storm-client/src/py/storm/DistributedRPC.py:277–296  ·  view source on GitHub ↗
(self, oprot)

Source from the content-addressed store, hash-verified

275 iprot.readStructEnd()
276
277 def write(self, oprot):
278 self.validate()
279 if oprot._fast_encode is not None and self.thrift_spec is not None:
280 oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
281 return
282 oprot.writeStructBegin('execute_result')
283 if self.success is not None:
284 oprot.writeFieldBegin('success', TType.STRING, 0)
285 oprot.writeString(self.success.encode('utf-8') if sys.version_info[0] == 2 else self.success)
286 oprot.writeFieldEnd()
287 if self.e is not None:
288 oprot.writeFieldBegin('e', TType.STRUCT, 1)
289 self.e.write(oprot)
290 oprot.writeFieldEnd()
291 if self.aze is not None:
292 oprot.writeFieldBegin('aze', TType.STRUCT, 2)
293 self.aze.write(oprot)
294 oprot.writeFieldEnd()
295 oprot.writeFieldStop()
296 oprot.writeStructEnd()
297
298 def validate(self):
299 return

Callers

nothing calls this directly

Calls 4

validateMethod · 0.95
writeMethod · 0.65
writeStringMethod · 0.45
encodeMethod · 0.45

Tested by

no test coverage detected