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:

java.io.Serializable, java.lang.Cloneable, java.lang.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

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator

PhysicalOperator.OriginalLocation

Field Summary

Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach

bags, buffer, data, earlyTermination, inpTuple, inputPlans, isToBeFlattenedArray, its, noItems, opsToBeReset, planLeafOps, processingPlan, resultTypes

Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator

alias, illustrator, input, inputAttached, inputs, lineageTracer, outputs, parentPlan, pigLogger, requestedParallelism, res, resultType

Fields inherited from class org.apache.pig.impl.plan.Operator

mKey

Constructor Summary

Constructors

Constructor and Description
POOptimizedForEach(OperatorKey k)
POOptimizedForEach(OperatorKey k, int rp)
POOptimizedForEach(OperatorKey k, int rp, java.util.List inp)
POOptimizedForEach(OperatorKey k, int rp, java.util.List<PhysicalPlan> inp, java.util.List<java.lang.Boolean> isToBeFlattened)
POOptimizedForEach(OperatorKey k, java.util.List inp)

Method Summary

Modifier and Type	Method and Description
POOptimizedForEach	clone() Make a deep copy of this operator.
Result	getNextTuple() 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.
java.lang.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

addOriginalLocation, addOriginalLocation, attachInput, 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, setIllustrator, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType

Methods inherited from class org.apache.pig.impl.plan.Operator

compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, toString, unsetProjectionMap

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

POOptimizedForEach

public POOptimizedForEach(OperatorKey k)

POOptimizedForEach

public POOptimizedForEach(OperatorKey k,
                          int rp,
                          java.util.List inp)

POOptimizedForEach

public POOptimizedForEach(OperatorKey k,
                          int rp)

POOptimizedForEach

public POOptimizedForEach(OperatorKey k,
                          java.util.List inp)

POOptimizedForEach

public POOptimizedForEach(OperatorKey k,
                          int rp,
                          java.util.List<PhysicalPlan> inp,
                          java.util.List<java.lang.Boolean> isToBeFlattened)

Method Detail

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 java.lang.String name()

Overrides:

name in class POForEach

getNextTuple

public Result getNextTuple()
                    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:

getNextTuple in class POForEach

Throws:

ExecException

clone

public POOptimizedForEach clone()
                         throws java.lang.CloneNotSupportedException

Make a deep copy of this operator.

Overrides:

clone in class POForEach

Throws:

java.lang.CloneNotSupportedException

See Also:

Do not use the clone method directly. Operators are cloned when logical plans are cloned using {@link LogicalPlanCloner}