-
class BasicBolt
Bases: object
-
initialize(stormconf, context)
-
process(tuple)
-
run()
-
class Bolt
Bases: object
-
initialize(stormconf, context)
-
process(tuple)
-
run()
-
class Spout
Bases: object
-
ack(id)
-
fail(id)
-
initialize(conf, context)
-
nextTuple()
-
run()
-
class Tuple(id, component, stream, task, values)
Bases: object
-
ack(tup)
-
emit(*args, **kwargs)
-
emitBolt(tup, stream=None, anchors=[], directTask=None)
-
emitDirect(task, *args, **kwargs)
-
emitSpout(tup, stream=None, id=None, directTask=None)
-
fail(tup)
-
initComponent()
-
json_decode(x)
-
json_encode(x)
-
log(msg)
-
readCommand()
-
readMsg()
-
readTaskIds()
-
readTuple()
-
sendMsgToParent(msg)
-
sendpid(heartbeatdir)
-
sync()