diff options
author | Patrick Simianer <p@simianer.de> | 2014-06-14 16:46:27 +0200 |
---|---|---|
committer | Patrick Simianer <p@simianer.de> | 2014-06-14 16:46:27 +0200 |
commit | 26c490f404731d053a6205719b6246502c07b449 (patch) | |
tree | 3aa721098f1251dfbf2249ecd2736434c13b1d48 /hadoop/wordcount/pipes/wordcount.h |
init
Diffstat (limited to 'hadoop/wordcount/pipes/wordcount.h')
-rw-r--r-- | hadoop/wordcount/pipes/wordcount.h | 34 |
1 files changed, 34 insertions, 0 deletions
diff --git a/hadoop/wordcount/pipes/wordcount.h b/hadoop/wordcount/pipes/wordcount.h new file mode 100644 index 0000000..5b08d49 --- /dev/null +++ b/hadoop/wordcount/pipes/wordcount.h @@ -0,0 +1,34 @@ +#ifndef __WORDCOUNT_HH__ +#define __WORDCOUNT_HH__ + + +#include <iostream> +#include <string> + +#include "hadoop/Pipes.hh" +#include "hadoop/TemplateFactory.hh" + +#include <boost/algorithm/string.hpp> +#include <boost/tokenizer.hpp> +#include <boost/lexical_cast.hpp> + +using namespace std; + + +class WordcountMapper : public HadoopPipes::Mapper +{ + public: + WordcountMapper(const HadoopPipes::TaskContext&) {}; + void map(HadoopPipes::MapContext &context); +}; + +class WordcountReducer : public HadoopPipes::Reducer +{ + public: + WordcountReducer(const HadoopPipes::TaskContext&) {}; + void reduce(HadoopPipes::ReduceContext &context); +}; + + +#endif + |