org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
Class PigGenericMapReduce.Map

java.lang.Object
  extended by org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.Text,Tuple,PigNullableWritable,org.apache.hadoop.io.Writable>
      extended by org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapBase
          extended by org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapBase
              extended by org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapReduce.Map
Direct Known Subclasses:
PigGenericMapReduce.MapWithPartitionIndex
Enclosing class:
PigGenericMapReduce

public static class PigGenericMapReduce.Map
extends org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapBase


Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapBase
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapBase.IllustratorContext
 
Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.Mapper
org.apache.hadoop.mapreduce.Mapper.Context
 
Field Summary
 
Fields inherited from class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapBase
errorInMap, keyType, mp, stores, tf
 
Constructor Summary
PigGenericMapReduce.Map()
           
 
Method Summary
 void collect(org.apache.hadoop.mapreduce.Mapper.Context oc, Tuple tuple)
           
 
Methods inherited from class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapBase
getIllustratorContext, inIllustrator
 
Methods inherited from class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapBase
cleanup, getKeyType, map, runPipeline, setKeyType, setMapPlan, 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

PigGenericMapReduce.Map

public PigGenericMapReduce.Map()
Method Detail

collect

public void collect(org.apache.hadoop.mapreduce.Mapper.Context oc,
                    Tuple tuple)
             throws InterruptedException,
                    IOException
Specified by:
collect in class PigGenericMapBase
Throws:
InterruptedException
IOException


Copyright © 2007-2012 The Apache Software Foundation