![]() |
| |||||||
| Hadoop::Streaming
simple interface to Hadoop Streaming |
Hadoop::Streaming::Combiner
Simplify writing Hadoop Streaming jobs. Combiner follows the same interface as Reducer. Requires a combine() function which will be called for each line of combiner data. Combiners are run on the same machine as the mapper as a pre-reduce reduction ste |
Hadoop::Streaming::Mapper
Simplify writing Hadoop Streaming Mapper jobs. Write a map() function and let this role handle the Stream interface. |
| Hadoop::Streaming::Reducer
Simplify writing Hadoop Streaming jobs. Write a reduce() function and let this role handle the Stream interface. This Reducer roll provides an iterator over the multiple values for a given key. |
Hadoop::Streaming::Reducer::Input
Parse input stream for reducer |
Hadoop::Streaming::Reducer::Input::Iterator
Collects values for each key together with an iterator interface |
| Hadoop::Streaming::Reducer::Input::ValuesIterator
Role providing access to values for a given key. |
Hadoop::Streaming::Role::Emitter
Role to provide emit, counter, and status interaction with Hadoop::Streaming. |
Hadoop::Streaming::Role::Iterator
Role to require has_next and next |
| Problems, suggestions, or comments to Randy Kobes. | Questions? Check the FAQ. | |
| Enable installations using PAR::WebStart. |