weka.distributed.hadoop

Class RecommenderSimilarityHadoopMapper

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.BytesWritable>

weka.distributed.hadoop.RecommenderSimilarityHadoopMapper

Direct Known Subclasses:

RecommenderSimilarityRowHadoopMapper

public class RecommenderSimilarityHadoopMapper
extends org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.BytesWritable>

Nested Class Summary

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

org.apache.hadoop.mapreduce.Mapper.Context

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_BUFFER_SIZE
static java.lang.String	SIMILARITY_MAP_TASK_OPTIONS The key in the Configuration that the options for this task are associated with

Constructor Summary

Constructors

Constructor and Description
RecommenderSimilarityHadoopMapper()

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanup(org.apache.hadoop.mapreduce.Mapper.Context context)

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

run

Methods inherited from class java.lang.Object

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

Field Detail

SIMILARITY_MAP_TASK_OPTIONS

public static final java.lang.String SIMILARITY_MAP_TASK_OPTIONS

The key in the Configuration that the options for this task are associated with

See Also:

Constant Field Values

DEFAULT_BUFFER_SIZE

public static final int DEFAULT_BUFFER_SIZE

See Also:

Constant Field Values

Constructor Detail

RecommenderSimilarityHadoopMapper

public RecommenderSimilarityHadoopMapper()

Method Detail

cleanup

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

Overrides:

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

Throws:

java.io.IOException