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

Method execute

storm-client/src/py/storm/DistributedRPC.py:58–66  ·  view source on GitHub ↗

Parameters: - functionName - funcArgs

(self, functionName, funcArgs)

Source from the content-addressed store, hash-verified

56 self._seqid = 0
57
58 def execute(self, functionName, funcArgs):
59 """
60 Parameters:
61 - functionName
62 - funcArgs
63
64 """
65 self.send_execute(functionName, funcArgs)
66 return self.recv_execute()
67
68 def send_execute(self, functionName, funcArgs):
69 self._oprot.writeMessageBegin('execute', TMessageType.CALL, self._seqid)

Callers

nothing calls this directly

Calls 2

send_executeMethod · 0.95
recv_executeMethod · 0.95

Tested by

no test coverage detected