com.datasalt.pangool.tuplemr.mapred
Class MapOnlyMapper<I1,I2,O1,O2>
java.lang.Object
org.apache.hadoop.mapreduce.Mapper<I1,I2,O1,O2>
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 classes/interfaces inherited from class org.apache.hadoop.mapreduce.Mapper |
org.apache.hadoop.mapreduce.Mapper.Context |
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 |
MapOnlyMapper
public MapOnlyMapper()
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.