Author image Andrew Grangaard
and 1 contributors

NAME

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

VERSION

version 0.110030

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) 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.