com.datasalt.pangool.tuplemr.mapred.lib.input
Class DelegatingMapper

java.lang.Object
  org.apache.hadoop.mapreduce.Mapper
      com.datasalt.pangool.tuplemr.mapred.lib.input.DelegatingMapper

public class DelegatingMapper
extends org.apache.hadoop.mapreduce.Mapper

An Mapper that delegates behavior of paths to multiple other mappers.

See Also:

PangoolMultipleInputs#addInputPath(Job, Path, org.apache.hadoop.mapreduce.InputFormat, Mapper)

Nested Class Summary

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

org.apache.hadoop.mapreduce.Mapper.Context

Field Summary

protected org.apache.hadoop.mapreduce.Mapper

delegate

Constructor Summary

DelegatingMapper()

Method Summary

void	run(org.apache.hadoop.mapreduce.Mapper.Context context)

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

cleanup, map, setup

Methods inherited from class java.lang.Object

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

Field Detail

delegate

protected org.apache.hadoop.mapreduce.Mapper delegate

Constructor Detail

DelegatingMapper

public DelegatingMapper()

Method Detail

run

public void run(org.apache.hadoop.mapreduce.Mapper.Context context)
         throws IOException,
                InterruptedException

Overrides:

run in class org.apache.hadoop.mapreduce.Mapper

Throws:

IOException

InterruptedException