org.archive.wayback.resourceindex.indexer.hadoop
Class Driver.MapClass

java.lang.Object
  org.apache.hadoop.mapred.MapReduceBase
      org.archive.wayback.resourceindex.indexer.hadoop.Driver.MapClass

All Implemented Interfaces:

org.apache.hadoop.io.Closeable, org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Mapper, org.archive.mapred.ARCRecordMapper

Enclosing class:

Driver

public static class Driver.MapClass
extends org.apache.hadoop.mapred.MapReduceBase
implements org.archive.mapred.ARCRecordMapper

Mapper which converts an ARCRecord into a CDX line.

Version:

$Date$, $Revision$

Author:

brad

Constructor Summary

Driver.MapClass()

Method Summary

void	map(org.apache.hadoop.io.WritableComparable key, org.apache.hadoop.io.Writable value, org.apache.hadoop.mapred.OutputCollector output, org.apache.hadoop.mapred.Reporter reporter)
void	onARCClose()
void	onARCOpen()

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

close, configure

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.mapred.JobConfigurable

configure

Methods inherited from interface org.apache.hadoop.io.Closeable

close

Constructor Detail

Driver.MapClass

public Driver.MapClass()

Method Detail

map

public void map(org.apache.hadoop.io.WritableComparable key,
                org.apache.hadoop.io.Writable value,
                org.apache.hadoop.mapred.OutputCollector output,
                org.apache.hadoop.mapred.Reporter reporter)
         throws java.io.IOException

Specified by:

map in interface org.apache.hadoop.mapred.Mapper

Throws:

java.io.IOException

onARCOpen

public void onARCOpen()
               throws java.io.IOException

Specified by:

onARCOpen in interface org.archive.mapred.ARCRecordMapper

Throws:

java.io.IOException

onARCClose

public void onARCClose()
                throws java.io.IOException

Specified by:

onARCClose in interface org.archive.mapred.ARCRecordMapper

Throws:

java.io.IOException