org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators
Class POOptimizedForEach
java.lang.Object
org.apache.pig.impl.plan.Operator<PhyPlanVisitor>
org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POOptimizedForEach
- All Implemented Interfaces:
- Serializable, Cloneable, Comparable<Operator>, Illustrable
public class POOptimizedForEach
- extends POForEach
A specialized version of POForeach with the difference
that in getNext(), it knows that "input" has already been
attached by its input operator which SHOULD be POJoinPackage
- See Also:
- Serialized Form
Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach |
bags, buffer, data, inpTuple, inputPlans, isToBeFlattenedArray, its, mTupleFactory, noItems, opsToBeReset, planLeafOps, processingPlan, resultTypes |
Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator |
alias, dummyBag, dummyBool, dummyDBA, dummyDouble, dummyFloat, dummyInt, dummyLong, dummyMap, dummyString, dummyTuple, illustrator, input, inputAttached, inputs, lineageTracer, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, resultType |
Fields inherited from class org.apache.pig.impl.plan.Operator |
mKey |
Method Summary |
POOptimizedForEach |
clone()
Make a deep copy of this operator. |
Result |
getNext(Tuple t)
Calls getNext on the generate operator inside the nested
physical plan and returns it maintaining an additional state
to denote the begin and end of the nested plan processing. |
String |
name()
|
void |
visit(PhyPlanVisitor v)
Visit this node with the provided visitor. |
Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach |
addInputPlan, attachInputToPlans, createTuple, getInputPlans, getLeaves, getOpsToBeReset, getToBeFlattened, illustratorMarkup, inProcessing, processPlan, setAccumEnd, setAccumStart, setAccumulative, setInputPlans, setOpsToBeReset, setToBeFlattened, setUpFlattens, supportsMultipleInputs, supportsMultipleOutputs |
Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator |
attachInput, cloneHelper, detachInput, getAlias, getAliasString, getDummy, getIllustrator, getInputs, getLogger, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getPigLogger, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isBlocking, isInputAttached, processInput, reset, setAlias, setIllustrator, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType |
POOptimizedForEach
public POOptimizedForEach(OperatorKey k)
POOptimizedForEach
public POOptimizedForEach(OperatorKey k,
int rp,
List inp)
POOptimizedForEach
public POOptimizedForEach(OperatorKey k,
int rp)
POOptimizedForEach
public POOptimizedForEach(OperatorKey k,
List inp)
POOptimizedForEach
public POOptimizedForEach(OperatorKey k,
int rp,
List<PhysicalPlan> inp,
List<Boolean> isToBeFlattened)
visit
public void visit(PhyPlanVisitor v)
throws VisitorException
- Description copied from class:
Operator
- Visit this node with the provided visitor. This should only be called by
the visitor class itself, never directly.
- Overrides:
visit
in class POForEach
- Parameters:
v
- Visitor to visit with.
- Throws:
VisitorException
- if the visitor has a problem.
name
public String name()
- Overrides:
name
in class POForEach
getNext
public Result getNext(Tuple t)
throws ExecException
- Calls getNext on the generate operator inside the nested
physical plan and returns it maintaining an additional state
to denote the begin and end of the nested plan processing.
- Overrides:
getNext
in class POForEach
- Throws:
ExecException
clone
public POOptimizedForEach clone()
throws CloneNotSupportedException
- Make a deep copy of this operator.
- Overrides:
clone
in class POForEach
- Throws:
CloneNotSupportedException
- See Also:
Do not use the clone method directly. Operators are cloned when logical plans
are cloned using {@link LogicalPlanCloner}
Copyright © ${year} The Apache Software Foundation