public class CombinerPackager extends Packager
Packager.PackageType
bags, distinct, illustrator, isKeyCompound, isKeyTuple, key, keyInfo, keyType, mBagFactory, mTupleFactory, parent, readOnce
Constructor and Description |
---|
CombinerPackager(Packager pkg,
boolean[] bags)
A new POPostCombinePackage will be constructed as a near clone of the
provided POPackage.
|
Modifier and Type | Method and Description |
---|---|
void |
attachInput(Object key,
DataBag[] bags,
boolean[] readOnce) |
Result |
getNext() |
Tuple |
getValueTuple(PigNullableWritable keyWritable,
NullableTuple ntup,
int index) |
void |
setKeyInfo(Map<Integer,Pair<Boolean,Map<Integer,Integer>>> keyInfo) |
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
public CombinerPackager(Packager pkg, boolean[] bags)
pkg
- POPackage to clone.bags
- for each field, indicates whether it should be a bag (true)
or a simple field (false).public void attachInput(Object key, DataBag[] bags, boolean[] readOnce) throws ExecException
attachInput
in class Packager
ExecException
public void setKeyInfo(Map<Integer,Pair<Boolean,Map<Integer,Integer>>> keyInfo)
setKeyInfo
in class Packager
keyInfo
- the keyInfo to setpublic Result getNext() throws ExecException
getNext
in class Packager
ExecException
public Tuple getValueTuple(PigNullableWritable keyWritable, NullableTuple ntup, int index) throws ExecException
getValueTuple
in class Packager
ExecException
Copyright © 2007-2017 The Apache Software Foundation