weka.distributed.hadoop

Class RecommenderSimilarityHadoopCombiner

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

weka.distributed.hadoop.RecommenderSimilarityHadoopCombiner

public class RecommenderSimilarityHadoopCombiner
extends RecommenderSimilarityHadoopReducer

Nested Class Summary

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

org.apache.hadoop.mapreduce.Reducer.Context

Field Summary

Fields inherited from class weka.distributed.hadoop.RecommenderSimilarityHadoopReducer

MATRIX_FILE_NAME, SIM_RECOMMENDER_FILE_NAME, SIMILARITY_WRITE_PATH

Constructor Summary

Constructors

Constructor and Description
RecommenderSimilarityHadoopCombiner()

Method Summary

Methods

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

Methods inherited from class weka.distributed.hadoop.RecommenderSimilarityHadoopReducer

cleanup, setup

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

Constructor Detail

RecommenderSimilarityHadoopCombiner

public RecommenderSimilarityHadoopCombiner()

Method Detail

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 RecommenderSimilarityHadoopReducer

Throws:

java.io.IOException