hadoop-mapreduce-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Zesheng Wu <wuzeshen...@gmail.com>
Subject Re:
Date Fri, 10 Jan 2014 23:57:15 GMT
Of course you can, you can think this as an independent runnable program.


2014/1/11 Andrea Barbato <and.barbato@gmail.com>

> Hi, i have a simple question.
> I have this example code:
>
> class WordCountMapper : public HadoopPipes::Mapper {public:
>   // constructor: does nothing
>   WordCountMapper( HadoopPipes::TaskContext& context ) { }
>   // map function: receives a line, outputs (word,"1") to reducer.
>   void map( HadoopPipes::MapContext& context ) { ... }
>   }};
> class WordCountReducer : public HadoopPipes::Reducer {public:
>   // constructor: does nothing
>   WordCountReducer(HadoopPipes::TaskContext& context) {}
>   // reduce function
>   void reduce( HadoopPipes::ReduceContext& context ) { ... }};
> int main(int argc, char *argv[]) {
>   return HadoopPipes::runTask(HadoopPipes::TemplateFactory<WordCountMapper,WordCountReducer>()
);}
>
> Can I write some code lines (like the I/O operations) in the main function
> body?
> Thanks in advance.
>



-- 
Best Wishes!

Yours, Zesheng

Mime
View raw message