edu.yale.cs.hadoopdb.benchmark
Class SelectionTaskHDFS.Map

java.lang.Object
  org.apache.hadoop.mapred.MapReduceBase
      edu.yale.cs.hadoopdb.benchmark.SelectionTaskHDFS.Map

All Implemented Interfaces:

java.io.Closeable, org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.IntWritable>

Enclosing class:

SelectionTaskHDFS

static class SelectionTaskHDFS.Map
extends org.apache.hadoop.mapred.MapReduceBase
implements org.apache.hadoop.mapred.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.IntWritable>

Field Summary

protected org.apache.hadoop.io.Text	outputKey
protected org.apache.hadoop.io.IntWritable	outputValue
protected int	PAGE_RANK_VALUE

Constructor Summary

SelectionTaskHDFS.Map()

Method Summary

void	configure(org.apache.hadoop.mapred.JobConf job)
void	map(org.apache.hadoop.io.LongWritable key, org.apache.hadoop.io.Text value, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Text,org.apache.hadoop.io.IntWritable> output, org.apache.hadoop.mapred.Reporter reporter)

Methods inherited from class org.apache.hadoop.mapred.MapReduceBase

close

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

Field Detail

outputKey

protected org.apache.hadoop.io.Text outputKey

outputValue

protected org.apache.hadoop.io.IntWritable outputValue

PAGE_RANK_VALUE

protected int PAGE_RANK_VALUE

Constructor Detail

SelectionTaskHDFS.Map

SelectionTaskHDFS.Map()

Method Detail

configure

public void configure(org.apache.hadoop.mapred.JobConf job)

Specified by:

configure in interface org.apache.hadoop.mapred.JobConfigurable

Overrides:

configure in class org.apache.hadoop.mapred.MapReduceBase

map

public void map(org.apache.hadoop.io.LongWritable key,
                org.apache.hadoop.io.Text value,
                org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Text,org.apache.hadoop.io.IntWritable> output,
                org.apache.hadoop.mapred.Reporter reporter)
         throws java.io.IOException

Specified by:

map in interface org.apache.hadoop.mapred.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.IntWritable>

Throws:

java.io.IOException