summaryrefslogtreecommitdiff
path: root/dtrain/test/wc_pipes
diff options
context:
space:
mode:
authorPatrick Simianer <p@simianer.de>2011-09-25 21:59:39 +0200
committerPatrick Simianer <p@simianer.de>2011-09-25 21:59:39 +0200
commit98f12432cf2dc4a906d13d17e122b457882df308 (patch)
treec454f2ad97704dadd336bd973c5799b7671c8df8 /dtrain/test/wc_pipes
parent4d8c300734c441821141f4bff044c439e004ff84 (diff)
removed old stuff
Diffstat (limited to 'dtrain/test/wc_pipes')
-rw-r--r--dtrain/test/wc_pipes/bible.txt.gzbin1193106 -> 0 bytes
-rw-r--r--dtrain/test/wc_pipes/jobconf.xml16
-rwxr-xr-xdtrain/test/wc_pipes/run.sh11
-rw-r--r--dtrain/test/wc_pipes/wordcount.cc38
-rw-r--r--dtrain/test/wc_pipes/wordcount.h34
5 files changed, 0 insertions, 99 deletions
diff --git a/dtrain/test/wc_pipes/bible.txt.gz b/dtrain/test/wc_pipes/bible.txt.gz
deleted file mode 100644
index a25a65d9..00000000
--- a/dtrain/test/wc_pipes/bible.txt.gz
+++ /dev/null
Binary files differ
diff --git a/dtrain/test/wc_pipes/jobconf.xml b/dtrain/test/wc_pipes/jobconf.xml
deleted file mode 100644
index facdbce6..00000000
--- a/dtrain/test/wc_pipes/jobconf.xml
+++ /dev/null
@@ -1,16 +0,0 @@
-<?xml version="1.0"?>
-<configuration>
- <property>
- <name>hadoop.pipes.executable</name>
- <value>path/to/dp_hadoop_pipes_test</value>
- </property>
- <property>
- <name>hadoop.pipes.java.recordreader</name>
- <value>true</value>
- </property>
- <property>
- <name>hadoop.pipes.java.recordwriter</name>
- <value>true</value>
- </property>
-</configuration>
-
diff --git a/dtrain/test/wc_pipes/run.sh b/dtrain/test/wc_pipes/run.sh
deleted file mode 100755
index de7d8aef..00000000
--- a/dtrain/test/wc_pipes/run.sh
+++ /dev/null
@@ -1,11 +0,0 @@
-#!/bin/sh
-
-HADOOP=~/z/hadoop-0.20.2/
-
-$HADOOP/bin/hadoop dfs -put wordcount wordcount
-
-$HADOOP/bin/hadoop pipes -D hadoop.pipes.java.recordreader=true \
- -D hadoop.pipes.java.recordwriter=true \
- -input in/bible.txt -output out/bible_out \
- -program ./wordcount
-
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 );
-}
-
diff --git a/dtrain/test/wc_pipes/wordcount.h b/dtrain/test/wc_pipes/wordcount.h
deleted file mode 100644
index c8fc8a29..00000000
--- a/dtrain/test/wc_pipes/wordcount.h
+++ /dev/null
@@ -1,34 +0,0 @@
-#ifndef __WORDCOUNT_HH__
-#define __WORDCOUNT_HH__
-
-
-#include <iostream>
-#include <string>
-
-#include "hadoop/Pipes.hh"
-#include "hadoop/TemplateFactory.hh"
-
-#include <boost/algorithm/string.hpp>
-#include <boost/tokenizer.hpp>
-#include <boost/lexical_cast.hpp>
-
-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
-