Dan Blanchard > IO-Storm-0.13 > IO::Storm::Bolt

Download:
IO-Storm-0.13.tar.gz

Dependencies

Annotate this POD

Website

View/Report Bugs
Module Version: 0.13   Source  

NAME ^

IO::Storm::Bolt - The base class for all IO::Storm Bolts.

VERSION ^

version 0.13

NAME ^

IO::Storm::Bolt - The base class for all IO::Storm Bolts.

VERSION ^

version 0.06

METHODS ^

initialize

Called immediately after the initial handshake with Storm and before the main run loop. A good place to initialize connections to data sources.

process

Process a single tuple of input. This should be overriden by subclasses

emit

Emit a tuple to a stream.

:param tuple: the Tuple payload to send to Storm, should contain only JSON-serializable data. :type tuple: arrayref :param stream: the ID of the stream to emit this tuple to. Specify ``undef`` to emit to default stream. :type stream: scalar :param anchors: IDs of the tuples (or the <IO::Storm::Tuple> instances) which the emitted tuples should be anchored to. If ``auto_anchor`` is set and you have not specified ``anchors``, ``anchors`` will be set to the incoming/most recent tuple ID(s). :type anchors: arrayref :param direct_task: the task to send the tuple to. :type direct_task: scalar

ack

Acknowledge a tuple. Argument can be either a Tuple or an ID.

fail

Fail a tuple. Argument can be either a Tuple or an ID.

run

Main run loop for all bolts.

Performs initial handshake with Storm and reads tuples handing them off to subclasses. Any exceptions are caught and logged back to Storm prior to the Perl process exiting.

Subclasses should **not** override this method.

AUTHORS ^

COPYRIGHT AND LICENSE ^

This software is copyright (c) 2014 by Infinity Interactive, Inc.

This is free software; you can redistribute it and/or modify it under the same terms as the Perl 5 programming language system itself.

AUTHORS ^

COPYRIGHT AND LICENSE ^

This software is copyright (c) 2014 by Educational Testing Service.

This is free software; you can redistribute it and/or modify it under the same terms as the Perl 5 programming language system itself.

syntax highlighting: