public class POFRJoin extends PhysicalOperator
PhysicalOperator.OriginalLocation
alias, illustrator, input, inputAttached, inputs, lineageTracer, outputs, parentPlan, pigLogger, requestedParallelism, res, 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) |
Modifier and Type | Method and Description |
---|---|
int |
getFragment() |
java.util.List<java.util.List<PhysicalPlan>> |
getJoinPlans() |
Result |
getNextTuple() |
FileSpec[] |
getReplFiles() |
Tuple |
illustratorMarkup(java.lang.Object in,
java.lang.Object out,
int eqClassIndex)
input tuple mark up to be illustrate-able
|
java.lang.String |
name() |
void |
setFragment(int fragment) |
void |
setReplFiles(FileSpec[] replFiles) |
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, clone, cloneHelper, 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
compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, toString, unsetProjectionMap
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 java.util.List<java.util.List<PhysicalPlan>> getJoinPlans()
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
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 illustratorCopyright © 2007-2012 The Apache Software Foundation