org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators
Class POPackageLite

java.lang.Object
  extended by org.apache.pig.impl.plan.Operator<PhyPlanVisitor>
      extended by org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
          extended by org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage
              extended by org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackageLite
All Implemented Interfaces:
Serializable, Cloneable, Comparable<Operator>, Illustrable

public class POPackageLite
extends POPackage

This package operator is a specialization of POPackage operator used for the specific case of the order by query. See JIRA 802 for more details.

See Also:
Serialized Form

Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage
POPackage.PackageType
 
Field Summary
 
Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage
distinct, isKeyTuple, keyAsTuple, keyInfo, mBagFactory, mTupleFactory
 
Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
alias, dummyBag, dummyBool, dummyDBA, dummyDouble, dummyFloat, dummyInt, dummyLong, dummyMap, dummyString, dummyTuple, illustrator, input, inputAttached, inputs, lineageTracer, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, resultType
 
Fields inherited from class org.apache.pig.impl.plan.Operator
mKey
 
Constructor Summary
POPackageLite(OperatorKey k)
           
POPackageLite(OperatorKey k, int rp)
           
POPackageLite(OperatorKey k, int rp, List<PhysicalOperator> inp)
           
POPackageLite(OperatorKey k, List<PhysicalOperator> inp)
           
 
Method Summary
 POPackageLite clone()
          Make a deep copy of this operator.
 boolean[] getInner()
           
 Object getKey()
           
 Tuple getKeyAsTuple()
           
 boolean getKeyTuple()
           
 Result getNext(Tuple t)
          Similar to POPackage.getNext except that only one input is expected with index 0 and ReadOnceBag is used instead of DefaultDataBag.
 Iterator<NullableTuple> getTupIter()
           
 Tuple getValueTuple(NullableTuple ntup, int index, Object key)
          Makes use of the superclass method, but this requires an additional parameter key passed by ReadOnceBag.
 Tuple illustratorMarkup(Object in, Object out, int eqClassIndex)
          input tuple mark up to be illustrate-able
 boolean isDistinct()
           
 String name()
           
 void setDistinct(boolean distinct)
           
 void setInner(boolean[] inner)
           
 void setNumInps(int numInps)
           
 
Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage
attachInput, detachInput, getKeyInfo, getKeyType, getNumInps, getPackageType, getValueTuple, setKeyInfo, setKeyTuple, setKeyType, setPackageType, setUseSecondaryKey, supportsMultipleInputs, supportsMultipleOutputs, visit
 
Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
attachInput, cloneHelper, getAlias, getAliasString, getDummy, getIllustrator, getInputs, getLogger, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getPigLogger, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isBlocking, isInputAttached, processInput, reset, setAccumEnd, setAccumStart, setAccumulative, setAlias, setIllustrator, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType
 
Methods inherited from class org.apache.pig.impl.plan.Operator
compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, toString, unsetProjectionMap
 
Methods inherited from class java.lang.Object
finalize, getClass, notify, notifyAll, wait, wait, wait
 

Constructor Detail

POPackageLite

public POPackageLite(OperatorKey k)

POPackageLite

public POPackageLite(OperatorKey k,
                     int rp)

POPackageLite

public POPackageLite(OperatorKey k,
                     List<PhysicalOperator> inp)

POPackageLite

public POPackageLite(OperatorKey k,
                     int rp,
                     List<PhysicalOperator> inp)
Method Detail

setNumInps

public void setNumInps(int numInps)
Overrides:
setNumInps in class POPackage

getInner

public boolean[] getInner()
Overrides:
getInner in class POPackage

setInner

public void setInner(boolean[] inner)
Overrides:
setInner in class POPackage

clone

public POPackageLite clone()
                    throws CloneNotSupportedException
Make a deep copy of this operator.

Overrides:
clone in class POPackage
Throws:
CloneNotSupportedException
See Also:
Do not use the clone method directly. Operators are cloned when logical plans are cloned using {@link LogicalPlanCloner}

isDistinct

public boolean isDistinct()
Overrides:
isDistinct in class POPackage
Returns:
the distinct

setDistinct

public void setDistinct(boolean distinct)
Overrides:
setDistinct in class POPackage
Parameters:
distinct - the distinct to set

getKeyTuple

public boolean getKeyTuple()
Returns:
the isKeyTuple

getKeyAsTuple

public Tuple getKeyAsTuple()
Returns:
the keyAsTuple

getTupIter

public Iterator<NullableTuple> getTupIter()
Returns:
the tupIter

getKey

public Object getKey()
Returns:
the key

getNext

public Result getNext(Tuple t)
               throws ExecException
Similar to POPackage.getNext except that only one input is expected with index 0 and ReadOnceBag is used instead of DefaultDataBag.

Overrides:
getNext in class POPackage
Throws:
ExecException

getValueTuple

public Tuple getValueTuple(NullableTuple ntup,
                           int index,
                           Object key)
                    throws ExecException
Makes use of the superclass method, but this requires an additional parameter key passed by ReadOnceBag. key of this instance will be set to null in detachInput call, but an instance of ReadOnceBag may have the original key that it uses. Therefore this extra argument is taken to temporarily set it before the call to the superclass method and then restore it.

Throws:
ExecException

name

public String name()
Overrides:
name in class POPackage

illustratorMarkup

public Tuple illustratorMarkup(Object in,
                               Object out,
                               int eqClassIndex)
Description copied from interface: Illustrable
input tuple mark up to be illustrate-able

Specified by:
illustratorMarkup in interface Illustrable
Overrides:
illustratorMarkup in class POPackage
Parameters:
in - input tuple
out - output tuple before wrapped in ExampleTuple
eqClassIndex - index into equivalence classes in illustrator
Returns:
tuple


Copyright © ${year} The Apache Software Foundation