org.openimaj.hadoop.tools.twitter.token.mode.dfidf

Class CountWordsAcrossTimeperiod.NonCombinedTimesReducer

java.lang.Object

org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.Text,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.BytesWritable>

org.openimaj.hadoop.tools.twitter.token.mode.dfidf.CountWordsAcrossTimeperiod.NonCombinedTimesReducer

Enclosing class:

CountWordsAcrossTimeperiod

public static class CountWordsAcrossTimeperiod.NonCombinedTimesReducer
extends org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.Text,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.BytesWritable>

reduce input: , ,... ] but unlike CountWordsAcrossTimeperiod.Reduce expects that each timeperiod may appear multiple times (i.e. each timeperiod was not combined!) reduce output: # ,...>

Author:

Sina Samangooei (ss@ecs.soton.ac.uk)

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.Reducer

org.apache.hadoop.mapreduce.Reducer.Context

Constructor Summary

Constructors

Constructor and Description
NonCombinedTimesReducer() default construct does nothing

Method Summary

Modifier and Type	Method and Description
protected void	loadOptions(org.apache.hadoop.mapreduce.Reducer.Context context)
protected void	reduce(org.apache.hadoop.io.Text word, Iterable<org.apache.hadoop.io.BytesWritable> values, org.apache.hadoop.mapreduce.Reducer.Context context)
protected void	setup(org.apache.hadoop.mapreduce.Reducer.Context context)

Methods inherited from class org.apache.hadoop.mapreduce.Reducer

cleanup, run

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NonCombinedTimesReducer

public NonCombinedTimesReducer()

default construct does nothing

Method Detail

loadOptions

protected void loadOptions(org.apache.hadoop.mapreduce.Reducer.Context context)
                    throws IOException

Throws:

IOException

setup

protected void setup(org.apache.hadoop.mapreduce.Reducer.Context context)
              throws IOException,
                     InterruptedException

Overrides:

setup in class org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.Text,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.BytesWritable>

Throws:

IOException

InterruptedException

reduce

protected void reduce(org.apache.hadoop.io.Text word,
                      Iterable<org.apache.hadoop.io.BytesWritable> values,
                      org.apache.hadoop.mapreduce.Reducer.Context context)
               throws IOException,
                      InterruptedException

Overrides:

reduce in class org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.Text,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.BytesWritable>

Throws:

IOException

InterruptedException