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 Class Summary

Nested classes/interfaces inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage

POPackage.PackageType

Nested classes/interfaces inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator

PhysicalOperator.OriginalLocation

Field Summary

Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage

distinct, isKeyCompound, isKeyTuple, keyAsTuple, keyInfo, mBagFactory, mTupleFactory

Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator

alias, illustrator, input, inputAttached, inputs, lineageTracer, outputs, parentPlan, pigLogger, requestedParallelism, res, resultType

Fields inherited from class org.apache.pig.impl.plan.Operator

mKey

Constructor Summary

Constructors

Constructor and Description
POPackageLite(OperatorKey k)
POPackageLite(OperatorKey k, int rp)
POPackageLite(OperatorKey k, int rp, List<PhysicalOperator> inp)
POPackageLite(OperatorKey k, List<PhysicalOperator> inp)

Method Summary

Methods

Modifier and Type	Method and Description
POPackageLite	clone() Make a deep copy of this operator.
boolean[]	getInner()
Object	getKey()
Tuple	getKeyAsTuple()
boolean	getKeyTuple()
Result	getNextTuple() 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, 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, getIllustrator, getInputs, getLogger, getNext, getNextBigDecimal, getNextBigInteger, getNextBoolean, getNextDataBag, getNextDataByteArray, getNextDateTime, getNextDouble, getNextFloat, getNextInteger, getNextLong, getNextMap, getNextString, getOriginalLocations, getPigLogger, getReporter, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isBlocking, isInputAttached, processInput, reset, setAccumEnd, setAccumStart, setAccumulative, 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

getNextTuple

public Result getNextTuple()
                    throws ExecException

Similar to POPackage.getNext except that only one input is expected with index 0 and ReadOnceBag is used instead of DefaultDataBag.

Overrides:

getNextTuple 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