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

java.lang.Object
  extended by PigMapBase
      extended by org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapReduce.Map
          extended by org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapReduce.MapWithPartitionIndex
Enclosing class:
PigGenericMapReduce

public static class PigGenericMapReduce.MapWithPartitionIndex
extends PigGenericMapReduce.Map

Used by Skewed Join


Constructor Summary
PigGenericMapReduce.MapWithPartitionIndex()
           
 
Method Summary
 void collect(org.apache.hadoop.mapreduce.Mapper.Context oc, Tuple tuple)
           
protected  void runPipeline(PhysicalOperator leaf)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

PigGenericMapReduce.MapWithPartitionIndex

public PigGenericMapReduce.MapWithPartitionIndex()
Method Detail

collect

public void collect(org.apache.hadoop.mapreduce.Mapper.Context oc,
                    Tuple tuple)
             throws InterruptedException,
                    IOException
Overrides:
collect in class PigGenericMapReduce.Map
Throws:
InterruptedException
IOException

runPipeline

protected void runPipeline(PhysicalOperator leaf)
                    throws IOException,
                           InterruptedException
Throws:
IOException
InterruptedException


Copyright © ${year} The Apache Software Foundation