weka.distributed.hadoop

Class RecommenderSimilarityHadoopReducer

java.lang.Object

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

weka.distributed.hadoop.RecommenderSimilarityHadoopReducer

Direct Known Subclasses:

RecommenderSimilarityHadoopCombiner, RecommenderSimilarityRowHadoopReducer

public class RecommenderSimilarityHadoopReducer
extends org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.BytesWritable>

Nested Class Summary

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

org.apache.hadoop.mapreduce.Reducer.Context

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	MATRIX_FILE_NAME The name of the file to output the serialized matrix to
static java.lang.String	SIM_RECOMMENDER_FILE_NAME The name of the file to output the serialized item-based recommender to
static java.lang.String	SIMILARITY_WRITE_PATH Path at which to store the serialized similarity matrix and serialized item-based recommender

Constructor Summary

Constructors

Constructor and Description
RecommenderSimilarityHadoopReducer()

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanup(org.apache.hadoop.mapreduce.Reducer.Context context)
void	reduce(org.apache.hadoop.io.LongWritable key, java.lang.Iterable<org.apache.hadoop.io.BytesWritable> values, org.apache.hadoop.mapreduce.Reducer.Context context)
void	setup(org.apache.hadoop.mapreduce.Reducer.Context context)

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

run

Methods inherited from class java.lang.Object

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

Field Detail

SIMILARITY_WRITE_PATH

public static final java.lang.String SIMILARITY_WRITE_PATH

Path at which to store the serialized similarity matrix and serialized item-based recommender

See Also:

Constant Field Values

MATRIX_FILE_NAME

public static final java.lang.String MATRIX_FILE_NAME

The name of the file to output the serialized matrix to

See Also:

Constant Field Values

SIM_RECOMMENDER_FILE_NAME

public static final java.lang.String SIM_RECOMMENDER_FILE_NAME

The name of the file to output the serialized item-based recommender to

See Also:

Constant Field Values

Constructor Detail

RecommenderSimilarityHadoopReducer

public RecommenderSimilarityHadoopReducer()

Method Detail

setup

public void setup(org.apache.hadoop.mapreduce.Reducer.Context context)
           throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

reduce

public void reduce(org.apache.hadoop.io.LongWritable key,
          java.lang.Iterable<org.apache.hadoop.io.BytesWritable> values,
          org.apache.hadoop.mapreduce.Reducer.Context context)
            throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

cleanup

public void cleanup(org.apache.hadoop.mapreduce.Reducer.Context context)
             throws java.io.IOException

Overrides:

cleanup in class org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.BytesWritable>

Throws:

java.io.IOException