com.datasalt.pangool.tuplemr
Class IdentityTupleMapper

java.lang.Object
  extended by org.apache.hadoop.mapreduce.Mapper<INPUT_KEY,INPUT_VALUE,DatumWrapper<ITuple>,org.apache.hadoop.io.NullWritable>
      extended by com.datasalt.pangool.tuplemr.TupleMapper<ITuple,org.apache.hadoop.io.NullWritable>
          extended by com.datasalt.pangool.tuplemr.IdentityTupleMapper
All Implemented Interfaces:
Serializable

public class IdentityTupleMapper
extends TupleMapper<ITuple,org.apache.hadoop.io.NullWritable>

See Also:
Serialized Form

Nested Class Summary
 
Nested classes/interfaces inherited from class com.datasalt.pangool.tuplemr.TupleMapper
TupleMapper.Collector, TupleMapper.StaticTupleMRContext<INPUT_KEY,INPUT_VALUE>, TupleMapper.TupleMRContext
 
Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.Mapper
org.apache.hadoop.mapreduce.Mapper.Context
 
Constructor Summary
IdentityTupleMapper()
           
 
Method Summary
 void map(ITuple key, org.apache.hadoop.io.NullWritable value, TupleMapper.TupleMRContext context, TupleMapper.Collector collector)
          Called once per each input pair of key/values.
 
Methods inherited from class com.datasalt.pangool.tuplemr.TupleMapper
cleanup, cleanup, map, setup, setup
 
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

IdentityTupleMapper

public IdentityTupleMapper()
Method Detail

map

public void map(ITuple key,
                org.apache.hadoop.io.NullWritable value,
                TupleMapper.TupleMRContext context,
                TupleMapper.Collector collector)
         throws IOException,
                InterruptedException
Description copied from class: TupleMapper
Called once per each input pair of key/values. Override it to implement your custom logic.

Specified by:
map in class TupleMapper<ITuple,org.apache.hadoop.io.NullWritable>
Throws:
IOException
InterruptedException


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