com.datasalt.pangool.tuplemr.mapred
Class MapOnlyMapper<I1,I2,O1,O2>

java.lang.Object
  extended by org.apache.hadoop.mapreduce.Mapper<I1,I2,O1,O2>
      extended by com.datasalt.pangool.tuplemr.mapred.MapOnlyMapper<I1,I2,O1,O2>
All Implemented Interfaces:
Serializable

public abstract class MapOnlyMapper<I1,I2,O1,O2>
extends org.apache.hadoop.mapreduce.Mapper<I1,I2,O1,O2>
implements Serializable

Mapper to be implemented by Map-only jobs.

See Also:
MapOnlyJobBuilder, Serialized Form

Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.Mapper
org.apache.hadoop.mapreduce.Mapper.Context
 
Constructor Summary
MapOnlyMapper()
           
 
Method Summary
protected  void cleanup(org.apache.hadoop.mapreduce.Mapper.Context context)
           
protected  void cleanup(org.apache.hadoop.mapreduce.Mapper.Context context, MultipleOutputsCollector mOuts)
          Override this method, not the other declared as final.
protected  void map(I1 key, I2 value, org.apache.hadoop.mapreduce.Mapper.Context context)
           
protected  void map(I1 key, I2 value, org.apache.hadoop.mapreduce.Mapper.Context context, MultipleOutputsCollector collector)
           
protected  void setup(org.apache.hadoop.mapreduce.Mapper.Context context)
          Deprecated. This method shouldn't be implemented, otherwise MultipleOutputs may not work. When implemented, super.setup() should be called if MultipleOutputs are to be used. Therefore we have created another signature with the MultipleOutputsCollector in order to avoid this, which will be the official setup() method in the future (this one will be declared final in further versions).
protected  void setup(org.apache.hadoop.mapreduce.Mapper.Context context, MultipleOutputsCollector mOuts)
          Override this method, not the other one.
 
Methods inherited from class org.apache.hadoop.mapreduce.Mapper
run
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MapOnlyMapper

public MapOnlyMapper()
Method Detail

map

protected void map(I1 key,
                   I2 value,
                   org.apache.hadoop.mapreduce.Mapper.Context context,
                   MultipleOutputsCollector collector)
            throws IOException,
                   InterruptedException
Throws:
IOException
InterruptedException

map

protected void map(I1 key,
                   I2 value,
                   org.apache.hadoop.mapreduce.Mapper.Context context)
            throws IOException,
                   InterruptedException
Overrides:
map in class org.apache.hadoop.mapreduce.Mapper<I1,I2,O1,O2>
Throws:
IOException
InterruptedException

setup

protected void setup(org.apache.hadoop.mapreduce.Mapper.Context context,
                     MultipleOutputsCollector mOuts)
              throws IOException,
                     InterruptedException
Override this method, not the other one. This one will be automatically called by the default setup() after initializing MultipleOutputs.

Throws:
IOException
InterruptedException

setup

protected void setup(org.apache.hadoop.mapreduce.Mapper.Context context)
              throws IOException,
                     InterruptedException
Deprecated. This method shouldn't be implemented, otherwise MultipleOutputs may not work. When implemented, super.setup() should be called if MultipleOutputs are to be used. Therefore we have created another signature with the MultipleOutputsCollector in order to avoid this, which will be the official setup() method in the future (this one will be declared final in further versions).

Overrides:
setup in class org.apache.hadoop.mapreduce.Mapper<I1,I2,O1,O2>
Throws:
IOException
InterruptedException

cleanup

protected void cleanup(org.apache.hadoop.mapreduce.Mapper.Context context,
                       MultipleOutputsCollector mOuts)
                throws IOException,
                       InterruptedException
Override this method, not the other declared as final.

Throws:
IOException
InterruptedException

cleanup

protected final void cleanup(org.apache.hadoop.mapreduce.Mapper.Context context)
                      throws IOException,
                             InterruptedException
Overrides:
cleanup in class org.apache.hadoop.mapreduce.Mapper<I1,I2,O1,O2>
Throws:
IOException
InterruptedException


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