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

Class CombinerPackager

java.lang.Object

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

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

All Implemented Interfaces:

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

public class CombinerPackager
extends Packager

The package operator that packages the globally rearranged tuples into output format after the combiner stage. It differs from POPackage in that it does not use the index in the NullableTuple to find the bag to put a tuple in. Instead, the inputs are put in a bag corresponding to their offset in the tuple.

See Also:

Serialized Form

Nested Class Summary

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

Packager.PackageType

Field Summary

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

bags, distinct, illustrator, isKeyCompound, isKeyTuple, key, keyInfo, keyType, mBagFactory, mTupleFactory, parent, readOnce

Constructor Summary

Constructors

Constructor and Description
CombinerPackager(Packager pkg, boolean[] bags) A new POPostCombinePackage will be constructed as a near clone of the provided POPackage.

Method Summary

Modifier and Type	Method and Description
void	attachInput(java.lang.Object key, DataBag[] bags, boolean[] readOnce)
Result	getNext()
Tuple	getValueTuple(PigNullableWritable keyWritable, NullableTuple ntup, int index)
void	setKeyInfo(java.util.Map<java.lang.Integer,Pair<java.lang.Boolean,java.util.Map<java.lang.Integer,java.lang.Integer>>> keyInfo)

Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.Packager

checkBagType, clone, detachInput, getBag, getIllustrator, getInner, getKey, getKey, getKeyAsTuple, getKeyInfo, getKeyTuple, getKeyType, getNumInputs, getNumInputs, getPackageType, getUseSecondaryKey, illustratorMarkup, illustratorMarkup2, isDistinct, name, numberOfEquivalenceClasses, setDistinct, setIllustrator, setInner, setKeyCompound, setKeyTuple, setKeyType, setNumInputs, setPackageType, setParent, setUseSecondaryKey, starMarkup

Methods inherited from class java.lang.Object

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

Constructor Detail

CombinerPackager

public CombinerPackager(Packager pkg,
                        boolean[] bags)

A new POPostCombinePackage will be constructed as a near clone of the provided POPackage.

Parameters:

pkg - POPackage to clone.

bags - for each field, indicates whether it should be a bag (true) or a simple field (false).

Method Detail

attachInput

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

Overrides:

attachInput in class Packager

Throws:

ExecException

setKeyInfo

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

Overrides:

setKeyInfo in class Packager

Parameters:

keyInfo - the keyInfo to set

getNext

public Result getNext()
               throws ExecException

Overrides:

getNext in class Packager

Throws:

ExecException

getValueTuple

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

Overrides:

getValueTuple in class Packager

Throws:

ExecException