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

Method send_execute

storm-client/src/py/storm/DistributedRPC.py:68–75  ·  view source on GitHub ↗
(self, functionName, funcArgs)

Source from the content-addressed store, hash-verified

66 return self.recv_execute()
67
68 def send_execute(self, functionName, funcArgs):
69 self._oprot.writeMessageBegin('execute', TMessageType.CALL, self._seqid)
70 args = execute_args()
71 args.functionName = functionName
72 args.funcArgs = funcArgs
73 args.write(self._oprot)
74 self._oprot.writeMessageEnd()
75 self._oprot.trans.flush()
76
77 def recv_execute(self):
78 iprot = self._iprot

Callers 1

executeMethod · 0.95

Calls 3

execute_argsClass · 0.70
writeMethod · 0.65
flushMethod · 0.65

Tested by

no test coverage detected