|
Class Summary |
| AggregateWordCount |
This is an example Aggregated Hadoop Map/Reduce application. |
| AggregateWordHistogram |
This is an example Aggregated Hadoop Map/Reduce application. |
| DBCountPageView |
This is a demonstrative program, which uses DBInputFormat for reading
the input data from a database, and DBOutputFormat for writing the data
to the database. |
| ExampleDriver |
A description of an example program based on its class and a
human-readable description. |
| Grep |
|
| Join |
This is the trivial map/reduce program that does absolutely nothing
other than use the framework to fragment and sort the input values. |
| MultiFileWordCount |
MultiFileWordCount is an example to demonstrate the usage of
MultiFileInputFormat. |
| MultiFileWordCount.MapClass |
This Mapper is similar to the one in WordCount.MapClass. |
| MultiFileWordCount.MultiFileLineRecordReader |
RecordReader is responsible from extracting records from the InputSplit. |
| MultiFileWordCount.MyInputFormat |
To use MultiFileInputFormat, one should extend it, to return a
(custom) RecordReader. |
| MultiFileWordCount.WordOffset |
This record keeps <filename,offset> pairs. |
| PiEstimator |
A Map-reduce program to estimaate the valu eof Pi using monte-carlo
method. |
| PiEstimator.PiMapper |
Mappper class for Pi estimation. |
SleepJob.SleepInputFormat
| RandomTextWriter |
This program uses map/reduce to just run a distributed job where there is
no interaction between the tasks and each task writes a large unsorted
random sequence of words. |
| RandomWriter |
This program uses map/reduce to just run a distributed job where there is
no interaction between the tasks and each task write a large unsorted
random binary sequence file of BytesWritable. |
| SleepJob |
Dummy class for testing MR framefork. |
| Sort<K,V> |
This is the trivial map/reduce program that does absolutely nothing
other than use the framework to fragment and sort the input values. |
| WordCount |
This is an example Hadoop Map/Reduce application. |
| WordCount.MapClass |
Counts the words in each line. |
| WordCount.Reduce |
A reducer class that just emits the sum of the input values. |