public class JoinPackager extends Packager
Packager.PackageType
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_CHUNK_SIZE |
bags, distinct, illustrator, isKeyCompound, isKeyTuple, key, keyInfo, keyType, mBagFactory, mTupleFactory, parent, readOnce
Constructor and Description |
---|
JoinPackager(Packager p,
POForEach f) |
Modifier and Type | Method and Description |
---|---|
void |
attachInput(Object key,
DataBag[] bags,
boolean[] readOnce) |
POOptimizedForEach |
getForEach() |
List<PhysicalPlan> |
getInputPlans() |
Result |
getNext()
Calls getNext to get next ForEach result.
|
String |
name() |
void |
setChunkSize(long chunkSize) |
void |
setIllustrator(Illustrator illustrator) |
void |
setInputPlans(List<PhysicalPlan> plans) |
void |
setToBeFlattened(List<Boolean> flattens) |
checkBagType, clone, detachInput, getBag, getIllustrator, getInner, getKey, getKey, getKeyAsTuple, getKeyInfo, getKeyTuple, getKeyType, getNumInputs, getNumInputs, getPackageType, getUseSecondaryKey, getValueTuple, illustratorMarkup, illustratorMarkup2, isDistinct, numberOfEquivalenceClasses, setDistinct, setInner, setKeyCompound, setKeyInfo, setKeyTuple, setKeyType, setNumInputs, setPackageType, setParent, setUseSecondaryKey, starMarkup
public static final String DEFAULT_CHUNK_SIZE
public Result getNext() throws ExecException
getNext
in class Packager
ExecException
public void attachInput(Object key, DataBag[] bags, boolean[] readOnce) throws ExecException
attachInput
in class Packager
ExecException
public List<PhysicalPlan> getInputPlans()
public void setInputPlans(List<PhysicalPlan> plans)
public POOptimizedForEach getForEach()
public void setChunkSize(long chunkSize)
chunkSize
- - the chunk size for the biggest inputpublic void setIllustrator(Illustrator illustrator)
setIllustrator
in interface Illustrable
setIllustrator
in class Packager
Copyright © 2007-2017 The Apache Software Foundation