#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