public class POFRJoin extends PhysicalOperator
Modifier and Type | Class and Description |
---|---|
protected static class |
POFRJoin.TupleToMapKey |
PhysicalOperator.OriginalLocation
Modifier and Type | Field and Description |
---|---|
protected ConstantExpression[] |
constExps |
protected Tuple |
dumTup |
protected POForEach |
fe |
protected int |
fragment |
protected Schema[] |
inputSchemas |
protected boolean |
isLeftOuterJoin |
protected Schema[] |
keySchemas |
protected java.util.List<java.util.List<java.lang.Byte>> |
keyTypes |
protected POLocalRearrange[] |
LRs |
protected DataBag |
nullBag |
protected java.util.List<java.util.List<PhysicalPlan>> |
phyPlanLists |
protected boolean |
processingPlan |
protected FileSpec[] |
replFiles |
protected java.util.List<java.util.Map<? extends java.lang.Object,? extends java.util.List<Tuple>>> |
replicates |
protected boolean |
setUp |
alias, illustrator, input, inputAttached, inputs, lineageTracer, mBagFactory, mTupleFactory, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType
Constructor and Description |
---|
POFRJoin(OperatorKey k,
int rp,
java.util.List<PhysicalOperator> inp,
java.util.List<java.util.List<PhysicalPlan>> ppLists,
java.util.List<java.util.List<java.lang.Byte>> keyTypes,
FileSpec[] replFiles,
int fragment,
boolean isLeftOuter,
Tuple nullTuple) |
POFRJoin(OperatorKey k,
int rp,
java.util.List<PhysicalOperator> inp,
java.util.List<java.util.List<PhysicalPlan>> ppLists,
java.util.List<java.util.List<java.lang.Byte>> keyTypes,
FileSpec[] replFiles,
int fragment,
boolean isLeftOuter,
Tuple nullTuple,
Schema[] inputSchemas,
Schema[] keySchemas) |
POFRJoin(POFRJoin copy) |
Modifier and Type | Method and Description |
---|---|
POFRJoin |
clone()
Make a copy of this operator.
|
int |
getFragment() |
java.util.List<java.util.List<PhysicalPlan>> |
getJoinPlans() |
POLocalRearrange[] |
getLRs() |
Result |
getNextTuple() |
FileSpec[] |
getReplFiles() |
protected Tuple |
getValueTuple(POLocalRearrange lr,
Tuple tuple) |
Tuple |
illustratorMarkup(java.lang.Object in,
java.lang.Object out,
int eqClassIndex)
input tuple mark up to be illustrate-able
|
protected boolean |
isKeyNull(java.lang.Object key) |
java.lang.String |
name() |
void |
setFragment(int fragment) |
void |
setReplFiles(FileSpec[] replFiles) |
protected void |
setUpHashMap()
Builds the HashMaps by reading each replicated input from the DFS using a
Load operator
|
boolean |
supportsMultipleInputs()
Indicates whether this operator supports multiple inputs.
|
boolean |
supportsMultipleOutputs()
Indicates whether this operator supports multiple outputs.
|
void |
visit(PhyPlanVisitor v)
Visit this node with the provided visitor.
|
addOriginalLocation, addOriginalLocation, attachInput, cloneHelper, clonePlans, copyAliasFrom, detachInput, getAlias, getAliasString, getIllustrator, getInputs, getLogger, getNext, getNextBigDecimal, getNextBigInteger, getNextBoolean, getNextDataBag, getNextDataByteArray, getNextDateTime, getNextDouble, getNextFloat, getNextInteger, getNextLong, getNextMap, getNextString, getOriginalLocations, getPigLogger, getReporter, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isBlocking, isInputAttached, processInput, reset, setAccumEnd, setAccumStart, setAccumulative, setIllustrator, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType, staticDataCleanup
compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, toString, unsetProjectionMap
protected int fragment
protected java.util.List<java.util.List<PhysicalPlan>> phyPlanLists
protected java.util.List<java.util.List<java.lang.Byte>> keyTypes
protected POLocalRearrange[] LRs
protected FileSpec[] replFiles
protected ConstantExpression[] constExps
protected POForEach fe
protected boolean isLeftOuterJoin
protected DataBag nullBag
protected Schema[] inputSchemas
protected Schema[] keySchemas
protected transient java.util.List<java.util.Map<? extends java.lang.Object,? extends java.util.List<Tuple>>> replicates
protected transient boolean processingPlan
protected transient Tuple dumTup
protected transient boolean setUp
public POFRJoin(OperatorKey k, int rp, java.util.List<PhysicalOperator> inp, java.util.List<java.util.List<PhysicalPlan>> ppLists, java.util.List<java.util.List<java.lang.Byte>> keyTypes, FileSpec[] replFiles, int fragment, boolean isLeftOuter, Tuple nullTuple) throws ExecException
ExecException
public POFRJoin(OperatorKey k, int rp, java.util.List<PhysicalOperator> inp, java.util.List<java.util.List<PhysicalPlan>> ppLists, java.util.List<java.util.List<java.lang.Byte>> keyTypes, FileSpec[] replFiles, int fragment, boolean isLeftOuter, Tuple nullTuple, Schema[] inputSchemas, Schema[] keySchemas) throws ExecException
ExecException
public POFRJoin(POFRJoin copy) throws ExecException
ExecException
public void visit(PhyPlanVisitor v) throws VisitorException
Operator
visit
in class PhysicalOperator
v
- Visitor to visit with.VisitorException
- if the visitor has a problem.public java.lang.String name()
name
in class Operator<PhyPlanVisitor>
public boolean supportsMultipleInputs()
Operator
supportsMultipleInputs
in class Operator<PhyPlanVisitor>
public boolean supportsMultipleOutputs()
Operator
supportsMultipleOutputs
in class Operator<PhyPlanVisitor>
public Result getNextTuple() throws ExecException
getNextTuple
in class PhysicalOperator
ExecException
protected void setUpHashMap() throws ExecException
ExecException
protected boolean isKeyNull(java.lang.Object key) throws ExecException
ExecException
protected Tuple getValueTuple(POLocalRearrange lr, Tuple tuple) throws ExecException
ExecException
public java.util.List<java.util.List<PhysicalPlan>> getJoinPlans()
public POLocalRearrange[] getLRs()
public int getFragment()
public void setFragment(int fragment)
public FileSpec[] getReplFiles()
public void setReplFiles(FileSpec[] replFiles)
public Tuple illustratorMarkup(java.lang.Object in, java.lang.Object out, int eqClassIndex)
Illustrable
in
- input tupleout
- output tuple before wrapped in ExampleTupleeqClassIndex
- index into equivalence classes in illustratorpublic POFRJoin clone() throws java.lang.CloneNotSupportedException
PhysicalOperator
clone
in class PhysicalOperator
java.lang.CloneNotSupportedException
Do not use the clone method directly. Operators are cloned when logical plans
are cloned using {@link LogicalPlanCloner}
Copyright © 2007-2012 The Apache Software Foundation