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

java.lang.Object
  extended by org.apache.hadoop.mapreduce.Mapper
      extended by 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


Copyright © –2014 Datasalt Systems S.L.. All rights reserved.