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

Class Packager

java.lang.Object

org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.Packager

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable, Illustrable

Direct Known Subclasses:

CombinerPackager, JoinPackager, LitePackager, MultiQueryPackager

public class Packager
extends java.lang.Object
implements Illustrable, java.io.Serializable, java.lang.Cloneable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Packager.PackageType

Field Summary

Fields

Modifier and Type	Field and Description
protected DataBag[]	bags
protected boolean	distinct
protected Illustrator	illustrator
protected boolean	isKeyCompound
protected boolean	isKeyTuple
protected java.util.Map<java.lang.Integer,Pair<java.lang.Boolean,java.util.Map<java.lang.Integer,java.lang.Integer>>>	keyInfo
protected static BagFactory	mBagFactory
protected static TupleFactory	mTupleFactory
protected POPackage	parent
protected boolean[]	readOnce

Constructor Summary

Constructors

Constructor and Description
Packager()

Method Summary

Methods

Modifier and Type	Method and Description
void	attachInput(java.lang.Object key, DataBag[] bags, boolean[] readOnce)
void	checkBagType()
Packager	clone()
void	detachInput()
DataBag	getBag()
Illustrator	getIllustrator()
boolean[]	getInner()
java.lang.Object	getKey()
java.lang.Object	getKey(PigNullableWritable key)
Tuple	getKeyAsTuple()
java.util.Map<java.lang.Integer,Pair<java.lang.Boolean,java.util.Map<java.lang.Integer,java.lang.Integer>>>	getKeyInfo()
boolean	getKeyTuple()
byte	getKeyType()
Result	getNext()
int	getNumInputs()
int	getNumInputs(byte index)
Packager.PackageType	getPackageType()
Tuple	getValueTuple(PigNullableWritable keyWritable, NullableTuple ntup, int index)
Tuple	illustratorMarkup(java.lang.Object in, java.lang.Object out, int eqClassIndex) input tuple mark up to be illustrate-able
protected Tuple	illustratorMarkup2(java.lang.Object in, java.lang.Object out)
boolean	isDistinct()
java.lang.String	name()
int	numberOfEquivalenceClasses()
void	setDistinct(boolean distinct)
void	setIllustrator(Illustrator illustrator)
void	setInner(boolean[] inner)
void	setKeyCompound(boolean keyCompound)
void	setKeyInfo(java.util.Map<java.lang.Integer,Pair<java.lang.Boolean,java.util.Map<java.lang.Integer,java.lang.Integer>>> keyInfo)
void	setKeyTuple(boolean keyTuple)
void	setKeyType(byte keyType)
void	setNumInputs(int numInputs)
void	setPackageType(Packager.PackageType type)
void	setParent(POPackage pack)
void	setUseSecondaryKey(boolean useSecondaryKey)
protected Tuple	starMarkup(Tuple key, Tuple val, Tuple out)

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

readOnce

protected boolean[] readOnce

bags

protected DataBag[] bags

illustrator

protected transient Illustrator illustrator

isKeyTuple

protected boolean isKeyTuple

isKeyCompound

protected boolean isKeyCompound

distinct

protected boolean distinct

keyInfo

protected java.util.Map<java.lang.Integer,Pair<java.lang.Boolean,java.util.Map<java.lang.Integer,java.lang.Integer>>> keyInfo

parent

protected POPackage parent

mBagFactory

protected static final BagFactory mBagFactory

mTupleFactory

protected static final TupleFactory mTupleFactory

Constructor Detail

Packager

public Packager()

Method Detail

getKey

public java.lang.Object getKey(PigNullableWritable key)
                        throws ExecException

Throws:

ExecException

attachInput

public void attachInput(java.lang.Object key,
               DataBag[] bags,
               boolean[] readOnce)
                 throws ExecException

Throws:

ExecException

getNext

public Result getNext()
               throws ExecException

Throws:

ExecException

detachInput

public void detachInput()

illustratorMarkup2

protected Tuple illustratorMarkup2(java.lang.Object in,
                       java.lang.Object out)

starMarkup

protected Tuple starMarkup(Tuple key,
               Tuple val,
               Tuple out)

getValueTuple

public Tuple getValueTuple(PigNullableWritable keyWritable,
                  NullableTuple ntup,
                  int index)
                    throws ExecException

Throws:

ExecException

getKeyType

public byte getKeyType()

setKeyType

public void setKeyType(byte keyType)

getKeyTuple

public boolean getKeyTuple()

Returns:

the isKeyTuple

getKeyAsTuple

public Tuple getKeyAsTuple()

Returns:

the keyAsTuple

getKey

public java.lang.Object getKey()

Returns:

the key

getInner

public boolean[] getInner()

setInner

public void setInner(boolean[] inner)

setKeyInfo

public void setKeyInfo(java.util.Map<java.lang.Integer,Pair<java.lang.Boolean,java.util.Map<java.lang.Integer,java.lang.Integer>>> keyInfo)

Parameters:

keyInfo - the keyInfo to set

setKeyTuple

public void setKeyTuple(boolean keyTuple)

Parameters:

keyTuple - the keyTuple to set

setKeyCompound

public void setKeyCompound(boolean keyCompound)

Parameters:

keyCompound - the keyCompound to set

getKeyInfo

public java.util.Map<java.lang.Integer,Pair<java.lang.Boolean,java.util.Map<java.lang.Integer,java.lang.Integer>>> getKeyInfo()

Returns:

the keyInfo

getIllustrator

public Illustrator getIllustrator()

setIllustrator

public void setIllustrator(Illustrator illustrator)

Specified by:

setIllustrator in interface Illustrable

isDistinct

public boolean isDistinct()

Returns:

the distinct

setDistinct

public void setDistinct(boolean distinct)

Parameters:

distinct - the distinct to set

setUseSecondaryKey

public void setUseSecondaryKey(boolean useSecondaryKey)

setPackageType

public void setPackageType(Packager.PackageType type)

getPackageType

public Packager.PackageType getPackageType()

getNumInputs

public int getNumInputs(byte index)

getNumInputs

public int getNumInputs()

setNumInputs

public void setNumInputs(int numInputs)

clone

public Packager clone()
               throws java.lang.CloneNotSupportedException

Overrides:

clone in class java.lang.Object

Throws:

java.lang.CloneNotSupportedException

name

public java.lang.String name()

illustratorMarkup

public Tuple illustratorMarkup(java.lang.Object in,
                      java.lang.Object out,
                      int eqClassIndex)

Description copied from interface: Illustrable

input tuple mark up to be illustrate-able

Specified by:

illustratorMarkup in interface Illustrable

Parameters:

in - input tuple

out - output tuple before wrapped in ExampleTuple

eqClassIndex - index into equivalence classes in illustrator

Returns:

tuple

setParent

public void setParent(POPackage pack)

numberOfEquivalenceClasses

public int numberOfEquivalenceClasses()

checkBagType

public void checkBagType()

getBag

public DataBag getBag()