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

Method write

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

Source from the content-addressed store, hash-verified

192 iprot.readStructEnd()
193
194 def write(self, oprot):
195 self.validate()
196 if oprot._fast_encode is not None and self.thrift_spec is not None:
197 oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
198 return
199 oprot.writeStructBegin('execute_args')
200 if self.functionName is not None:
201 oprot.writeFieldBegin('functionName', TType.STRING, 1)
202 oprot.writeString(self.functionName.encode('utf-8') if sys.version_info[0] == 2 else self.functionName)
203 oprot.writeFieldEnd()
204 if self.funcArgs is not None:
205 oprot.writeFieldBegin('funcArgs', TType.STRING, 2)
206 oprot.writeString(self.funcArgs.encode('utf-8') if sys.version_info[0] == 2 else self.funcArgs)
207 oprot.writeFieldEnd()
208 oprot.writeFieldStop()
209 oprot.writeStructEnd()
210
211 def validate(self):
212 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