Skip to content
Find file
Fetching contributors…
Cannot retrieve contributors at this time
109 lines (58 sloc) 1.75 KB

NAME

IO::Storm - Perl support for Twitter's Storm

DEPRECATED

Please use Dan Blanchard's Fork instead!

VERSION

version 0.01

SYNOPSIS

package SplitSentenceBolt;
use Moose;

extends 'Storm::BasicBolt';

sub process {
    my ($self, $tuple) = @_;

    my @words = split(' ', $tuple->values->[0]);
    foreach my $word (@words) {

        $self->emit([ $word ]);
    }
}

SplitSentenceBolt->new->run;

DESCRIPTION

IO::Storm allows you to leverage Storm's multilang support to write Bolts (and someday, more) in Perl.

METHODS

read_string_message

Read a message from the ShellBolt. Reads until it finds a "end" line.

read_message

Read a message from the ShellBolt and decode it from JSON.

send_message_to_parent

Sent a message to the ShellBolt, encoding it as JSON.

send_to_parent

Send a message to the ShellBolt.

sync

Send a sync.

send_pid

Send this processes PID.

emit_tuple

Send a tuple to the ShellBolt.

emit

Emit a tuple to the the ShellBolt and return the response.

emit_direct

Emit a tuple to the Shell bolt, but do not get a response.

ack

Acknowledge a tuple.

fail

Fail a tuple.

log

Send a log command to the ShellBolt

read_env

Read the configuration and context from the ShellBolt.

read_tuple

Turn the incoming Tuple structure into an IO::Storm::Tuple.

init_bolt

Initialize this bolt.

AUTHOR

Cory G Watson gphat@cpan.org

COPYRIGHT AND LICENSE

This software is copyright (c) 2011 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.

Something went wrong with that request. Please try again.