public class POOptimizedForEach extends POForEach
PhysicalOperator.OriginalLocation
bags, buffer, data, earlyTermination, endOfAllInputProcessed, endOfAllInputProcessing, inpTuple, inputPlans, isToBeFlattenedArray, its, mapSideOnly, noItems, opsToBeReset, planLeafOps, processingPlan, resultTypes, tIn
alias, illustrator, input, inputAttached, inputs, lineageTracer, mBagFactory, mTupleFactory, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType
Constructor and Description |
---|
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) |
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.
|
String |
name() |
void |
visit(PhyPlanVisitor v)
Visit this node with the provided visitor.
|
addInputPlan, attachInputToPlans, createTuple, getInputPlans, getLeaves, getOpsToBeReset, getPlanLeafOps, getToBeFlattened, illustratorMarkup, inProcessing, isMapSideOnly, needEndOfAllInputProcessing, processPlan, setAccumEnd, setAccumStart, setAccumulative, setInputPlans, setMapSideOnly, setOpsToBeReset, setToBeFlattened, setUpFlattens, supportsMultipleInputs, supportsMultipleOutputs
addOriginalLocation, addOriginalLocation, attachInput, 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, setIllustrator, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType, staticDataCleanup
compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, toString, unsetProjectionMap
public POOptimizedForEach(OperatorKey k)
public POOptimizedForEach(OperatorKey k, int rp, List inp)
public POOptimizedForEach(OperatorKey k, int rp)
public POOptimizedForEach(OperatorKey k, List inp)
public POOptimizedForEach(OperatorKey k, int rp, List<PhysicalPlan> inp, List<Boolean> isToBeFlattened)
public void visit(PhyPlanVisitor v) throws VisitorException
Operator
visit
in class POForEach
v
- Visitor to visit with.VisitorException
- if the visitor has a problem.public Result getNextTuple() throws ExecException
getNextTuple
in class POForEach
ExecException
public POOptimizedForEach clone() throws CloneNotSupportedException
clone
in class POForEach
CloneNotSupportedException
Do not use the clone method directly. Operators are cloned when logical plans
are cloned using {@link LogicalPlanCloner}
Copyright © 2007-2017 The Apache Software Foundation