diff options
Diffstat (limited to 'dtrain/scfg/features/count/featurecount.h')
-rw-r--r-- | dtrain/scfg/features/count/featurecount.h | 32 |
1 files changed, 32 insertions, 0 deletions
diff --git a/dtrain/scfg/features/count/featurecount.h b/dtrain/scfg/features/count/featurecount.h new file mode 100644 index 00000000..9431534f --- /dev/null +++ b/dtrain/scfg/features/count/featurecount.h @@ -0,0 +1,32 @@ +#ifndef __FEATURECOUNT_HH__ +#define __FEATURECOUNT_HH__ + +#include "hadoop/Pipes.hh" +#include "hadoop/TemplateFactory.hh" +#include "hadoop/StringUtils.hh" +#include <iostream> +#include <string> +#include <boost/algorithm/string.hpp> +#include <boost/tokenizer.hpp> +#include <boost/lexical_cast.hpp> + +using namespace std; + + +class FeatureCountMapper : public HadoopPipes::Mapper +{ + public: + FeatureCountMapper( const HadoopPipes::TaskContext& ) {}; + void map( HadoopPipes::MapContext &context ); +}; + +class FeatureCountReducer : public HadoopPipes::Reducer +{ + public: + FeatureCountReducer( const HadoopPipes::TaskContext& ) {}; + void reduce( HadoopPipes::ReduceContext & context ); +}; + + +#endif + |