summaryrefslogtreecommitdiff
path: root/dtrain/test/wc_pipes/wordcount.cc
diff options
context:
space:
mode:
Diffstat (limited to 'dtrain/test/wc_pipes/wordcount.cc')
-rw-r--r--dtrain/test/wc_pipes/wordcount.cc38
1 files changed, 0 insertions, 38 deletions
diff --git a/dtrain/test/wc_pipes/wordcount.cc b/dtrain/test/wc_pipes/wordcount.cc
deleted file mode 100644
index 39560a31..00000000
--- a/dtrain/test/wc_pipes/wordcount.cc
+++ /dev/null
@@ -1,38 +0,0 @@
-#include "wordcount.hh"
-
-
-void
-WordcountMapper::map(HadoopPipes::MapContext & context)
-{
- typedef boost::tokenizer<> tokenizer_t;
- tokenizer_t tokenizer(context.getInputValue());
-
- for( tokenizer_t::const_iterator i = tokenizer.begin();
- tokenizer.end() != i; ++i ) {
- context.emit(boost::to_lower_copy(*i), "1");
- }
-}
-
-void
-WordcountReducer::reduce(HadoopPipes::ReduceContext & context)
-{
- uint32_t count( 0 );
-
- do {
- ++count;
- } while( context.nextValue() );
-
- std::cout << context.getInputKey() << endl;
- context.emit( context.getInputKey(),
- boost::lexical_cast<std::string>(count) );
-}
-
-
-int
-main( int argc, char * argv[] )
-{
- HadoopPipes::TemplateFactory2<WordcountMapper,
- WordcountReducer> factory;
- return HadoopPipes::runTask( factory );
-}
-