public class POPreCombinerLocalRearrange extends PhysicalOperator
PhysicalOperator.OriginalLocation
Modifier and Type | Field and Description |
---|---|
protected byte |
keyType |
protected java.util.List<ExpressionOperator> |
leafOps |
protected java.util.List<PhysicalPlan> |
plans |
protected static long |
serialVersionUID |
alias, illustrator, input, inputAttached, inputs, lineageTracer, mBagFactory, mTupleFactory, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType
Constructor and Description |
---|
POPreCombinerLocalRearrange(OperatorKey k) |
POPreCombinerLocalRearrange(OperatorKey k,
int rp) |
POPreCombinerLocalRearrange(OperatorKey k,
int rp,
java.util.List<PhysicalOperator> inp) |
POPreCombinerLocalRearrange(OperatorKey k,
java.util.List<PhysicalOperator> inp) |
Modifier and Type | Method and Description |
---|---|
void |
attachInput(Tuple t)
Overridden since the attachment of the new input should cause the old
processing to end.
|
POPreCombinerLocalRearrange |
clone()
Make a copy of this operator.
|
protected Tuple |
constructLROutput(java.util.List<Result> resLst,
Tuple value) |
byte |
getKeyType() |
Result |
getNextTuple()
Calls getNext on the generate operator inside the nested
physical plan.
|
java.util.List<PhysicalPlan> |
getPlans() |
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 |
setKeyType(byte keyType) |
void |
setPlans(java.util.List<PhysicalPlan> plans) |
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, cloneHelper, clonePlans, copyAliasFrom, detachInput, getAlias, getAliasString, getIllustrator, getInputs, getLogger, getNext, getNextBigDecimal, getNextBigInteger, getNextBoolean, getNextDataBag, getNextDataByteArray, getNextDateTime, getNextDouble, getNextFloat, getNextInteger, getNextLong, getNextMap, getNextString, getOriginalLocations, getParentPlan, getPigLogger, getReporter, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isBlocking, isEndOfAllInput, isInputAttached, processInput, reset, setAccumEnd, setAccumStart, setAccumulative, setIllustrator, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType, staticDataCleanup
compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, toString, unsetProjectionMap
protected static final long serialVersionUID
protected java.util.List<PhysicalPlan> plans
protected java.util.List<ExpressionOperator> leafOps
protected byte keyType
public POPreCombinerLocalRearrange(OperatorKey k)
public POPreCombinerLocalRearrange(OperatorKey k, int rp)
public POPreCombinerLocalRearrange(OperatorKey k, java.util.List<PhysicalOperator> inp)
public POPreCombinerLocalRearrange(OperatorKey k, int rp, java.util.List<PhysicalOperator> inp)
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 void attachInput(Tuple t)
attachInput
in class PhysicalOperator
t
- -
The tuple that should be used as inputpublic Result getNextTuple() throws ExecException
getNextTuple
in class PhysicalOperator
ExecException
protected Tuple constructLROutput(java.util.List<Result> resLst, Tuple value) throws ExecException
ExecException
public byte getKeyType()
public void setKeyType(byte keyType)
public java.util.List<PhysicalPlan> getPlans()
public void setPlans(java.util.List<PhysicalPlan> plans)
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 POPreCombinerLocalRearrange 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-2025 The Apache Software Foundation