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


Hadoop-Streaming documentation  | view source Contained in the Hadoop-Streaming distribution.

Index


NAME

Top

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

VERSION

Top

version 0.110030

METHODS

Top

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

Top

COPYRIGHT AND LICENSE

Top


Hadoop-Streaming documentation  | view source Contained in the Hadoop-Streaming distribution.