org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators
Class POPackageLite
java.lang.Object
org.apache.pig.impl.plan.Operator<PhyPlanVisitor>
org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage
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 classes/interfaces inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage |
POPackage.PackageType |
Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator |
alias, dummyBag, dummyBool, dummyDateTime, 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 |
Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage |
attachInput, detachInput, getKeyInfo, getKeyType, getNumInps, getPackageType, getValueTuple, setKeyCompound, setKeyInfo, setKeyTuple, setKeyType, setPackageType, setUseSecondaryKey, supportsMultipleInputs, supportsMultipleOutputs, visit |
Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator |
addOriginalLocation, addOriginalLocation, attachInput, cloneHelper, getAlias, getAliasString, getDummy, getIllustrator, getInputs, getLogger, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getOriginalLocations, getPigLogger, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isBlocking, isInputAttached, processInput, reset, setAccumEnd, setAccumStart, setAccumulative, setIllustrator, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType |
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)
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 tupleout
- output tuple before wrapped in ExampleTupleeqClassIndex
- index into equivalence classes in illustrator
- Returns:
- tuple
Copyright © 2007-2012 The Apache Software Foundation