#ifndef __WORDCOUNT_HH__ #define __WORDCOUNT_HH__ #include #include #include "hadoop/Pipes.hh" #include "hadoop/TemplateFactory.hh" #include #include #include 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