org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators
Class POOptimizedForEach

java.lang.Object
  extended by org.apache.pig.impl.plan.Operator<PhyPlanVisitor>
      extended by org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
          extended by org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach
              extended by 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

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
POOptimizedForEach(OperatorKey k)
           
POOptimizedForEach(OperatorKey k, int rp)
           
POOptimizedForEach(OperatorKey k, int rp, List inp)
           
POOptimizedForEach(OperatorKey k, int rp, List<PhysicalPlan> inp, List<Boolean> isToBeFlattened)
           
POOptimizedForEach(OperatorKey k, List inp)
           
 
Method Summary
 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.
 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,
                          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)
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 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 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 © 2007-2012 The Apache Software Foundation