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:

Serializable, Cloneable, Illustrable

Direct Known Subclasses:

BloomPackager, CombinerPackager, JoinPackager, LitePackager, MultiQueryPackager

public class Packager
extends Object
implements Illustrable, Serializable, 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 Object	key
protected Map<Integer,Pair<Boolean,Map<Integer,Integer>>>	keyInfo
protected byte	keyType
protected static BagFactory	mBagFactory
protected static TupleFactory	mTupleFactory
protected POPackage	parent
protected boolean[]	readOnce

Constructor Summary

Constructors

Constructor and Description
Packager()

Method Summary

Modifier and Type	Method and Description
void	attachInput(Object key, DataBag[] bags, boolean[] readOnce)
void	checkBagType()
Packager	clone()
void	detachInput()
DataBag	getBag()
Illustrator	getIllustrator()
boolean[]	getInner()
Object	getKey()
Object	getKey(PigNullableWritable key)
Tuple	getKeyAsTuple()
Map<Integer,Pair<Boolean,Map<Integer,Integer>>>	getKeyInfo()
boolean	getKeyTuple()
byte	getKeyType()
Result	getNext()
int	getNumInputs()
int	getNumInputs(byte index)
Packager.PackageType	getPackageType()
boolean	getUseSecondaryKey()
Tuple	getValueTuple(PigNullableWritable keyWritable, NullableTuple ntup, int index)
Tuple	illustratorMarkup(Object in, Object out, int eqClassIndex) input tuple mark up to be illustrate-able
protected Tuple	illustratorMarkup2(Object in, Object out)
boolean	isDistinct()
String	name()
int	numberOfEquivalenceClasses()
void	setDistinct(boolean distinct)
void	setIllustrator(Illustrator illustrator)
void	setInner(boolean[] inner)
void	setKeyCompound(boolean keyCompound)
void	setKeyInfo(Map<Integer,Pair<Boolean,Map<Integer,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

key

protected Object key

isKeyTuple

protected boolean isKeyTuple

isKeyCompound

protected boolean isKeyCompound

keyType

protected byte keyType

distinct

protected boolean distinct

keyInfo

protected Map<Integer,Pair<Boolean,Map<Integer,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 Object getKey(PigNullableWritable key)
              throws ExecException

Throws:

ExecException

attachInput

public void attachInput(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(Object in,
                                   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 Object getKey()

Returns:

the key

getInner

public boolean[] getInner()

setInner

public void setInner(boolean[] inner)

setKeyInfo

public void setKeyInfo(Map<Integer,Pair<Boolean,Map<Integer,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 Map<Integer,Pair<Boolean,Map<Integer,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)

getUseSecondaryKey

public boolean getUseSecondaryKey()

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 CloneNotSupportedException

Overrides:

clone in class Object

Throws:

CloneNotSupportedException

name

public String name()

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

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()