/ 
Hadoop-Streaming-0.103190
River stage zero No dependents
/ Hadoop::Streaming::Reducer::Input

NAME

Hadoop::Streaming::Reducer::Input - Parse input stream for reducer

VERSION

version 0.103190

METHODS

next_key

$Input->next_key();

Parses the next line into key/value (splits on tab) and returns the key portion.

Returns undef if there is no next line.

next_line

$Input->next_line();

Reads the next line into buffer and returns it.

Returns undef if there are no more lines (end of file).

getline

$Input->getline();

Returns the next available line. Clears the internal line buffer if set.

iterator

$Input->iterator();

Returns a new Hadoop::Streaming::Reducer::Input::Iterator for this object.

each

$Input->each();

Grabs the next line and splits on tabs. Returns an array containing the output of the split.

AUTHORS

  • andrew grangaard <spazm@cpan.org>

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

COPYRIGHT AND LICENSE

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