Differences
This shows you the differences between two versions of the page.
Both sides previous revision Previous revision | Next revision Both sides next revision | ||
courses:mapreduce-tutorial:step-24 [2012/01/27 21:41] straka |
courses:mapreduce-tutorial:step-24 [2012/01/27 21:47] straka |
||
---|---|---|---|
Line 3: | Line 3: | ||
We start by going through a simple Hadoop job with Mapper only. | We start by going through a simple Hadoop job with Mapper only. | ||
- | A mapper which processes (key, value) pairs of types (Kin, Vin) and produces (key, value) pairs of types (Kout, Vout) must be a subclass of [[http:// | + | A mapper which processes (key, value) pairs of types (Kin, Vin) and produces (key, value) pairs of types (Kout, Vout) must be a subclass of [[http:// |
+ | The mapper must define a '' | ||
+ | <code java> | ||
+ | public static class TheMapper extends Mapper< | ||
+ | public void setup(Context context) throws IOException, | ||
- | http:// | + | public void map(Text key, Text value, Context context) throws IOException, |
- | The Mapper outputs only keys starting with '' | + | public void cleanup(Context context) throws IOException, |
+ | } | ||
+ | </ | ||
+ | |||
+ | Outputting (key, value) pairs is performed using the [[http:// | ||
<file java MapperOnlyHadoopJob.java> | <file java MapperOnlyHadoopJob.java> |