You are viewing a plain text version of this content. The canonical link for it is here.
Posted to mapreduce-user@hadoop.apache.org by Andrea Barbato <an...@gmail.com> on 2014/01/10 17:44:50 UTC
Hadoop Pipes C++ Simple Question
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.