/ 
Hadoop-Streaming-0.110030
River stage zero No dependents
/ Hadoop::Streaming::Role::Emitter

NAME

Hadoop::Streaming::Role::Emitter - Role to provide emit, counter, and status interaction with Hadoop::Streaming.

VERSION

version 0.110030

METHODS

emit

$object->emit( $key, $value )

This method emits a key,value pair in the format expected by Hadoop::Streaming. It does this by calling $self->put(). This catches errors from put and turns them into warnings.

put

$object->put( $key, $value )

This method emits a key,value pair to STDOUT in the format expected by Hadoop::Streaming: ( key \t value \n )

counter

$object->counter(
    group   => $group,
    counter => $countername,
    amount  => $count,
);

This method emits a counter key to STDERR in the format expected by hadoop: reporter:counter:<group>,<counter>,<amount>

status

$object->status( $message )

This method emits a status message to STDERR in the format expected by Hadoop::Streaming: reporter:status:$message\n

AUTHORS

  • andrew grangaard <spazm@cpan.org>

  • Naoya Ito <naoya@hatena.ne.jp>

COPYRIGHT AND LICENSE

This software is copyright (c) 2011 by Naoya Ito <naoya@hatena.ne.jp>.

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