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

java.lang.Object
  org.apache.hadoop.mapred.MapReduceBase
      edu.yale.cs.hadoopdb.benchmark.GrepTaskHDFS.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.Text>

Enclosing class:

GrepTaskHDFS

static class GrepTaskHDFS.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.Text>

Field Summary

private org.apache.hadoop.io.Text	oKey
private org.apache.hadoop.io.Text	oValue
private static java.lang.String	pattern

Constructor Summary

GrepTaskHDFS.Map()

Method Summary

void	configure(org.apache.hadoop.mapred.JobConf job)
void	map(org.apache.hadoop.io.LongWritable key, org.apache.hadoop.io.Text field, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> 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

oKey

private org.apache.hadoop.io.Text oKey

oValue

private org.apache.hadoop.io.Text oValue

pattern

private static java.lang.String pattern

Constructor Detail

GrepTaskHDFS.Map

GrepTaskHDFS.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 field,
                org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> 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.Text>

Throws:

java.io.IOException