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

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

public static class PigGenericMapReduce.MapWithComparator
extends PigMapBase

This "specialized" map class is ONLY to be used in pig queries with order by a udf. A UDF used for comparison in the order by expects to be handed tuples. Hence this map class ensures that the "key" used in the order by is wrapped into a tuple (if it isn't already a tuple)


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

Constructor Detail

PigGenericMapReduce.MapWithComparator

public PigGenericMapReduce.MapWithComparator()
Method Detail

collect

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


Copyright © ${year} The Apache Software Foundation