public class PORelationToExprProject extends POProject
PhysicalOperator.OriginalLocation
columns, isProjectToEnd, overloaded, startCol
alias, illustrator, input, inputAttached, inputs, lineageTracer, mBagFactory, mTupleFactory, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType
Constructor and Description |
---|
PORelationToExprProject(OperatorKey k) |
PORelationToExprProject(OperatorKey k,
int rp) |
PORelationToExprProject(OperatorKey k,
int rp,
ArrayList<Integer> cols) |
PORelationToExprProject(OperatorKey k,
int rp,
int col) |
Modifier and Type | Method and Description |
---|---|
PORelationToExprProject |
clone()
Make a deep copy of this operator.
|
Result |
getNextDataBag() |
String |
name() |
void |
reset()
Reset internal state in an operator.
|
void |
visit(PhyPlanVisitor v)
Visit this node with the provided visitor.
|
attachInput, consumeInputBag, getChildExpressions, getColumn, getColumns, getNext, getNextBigDecimal, getNextBigInteger, getNextBoolean, getNextDataByteArray, getNextDateTime, getNextDouble, getNextFloat, getNextInteger, getNextLong, getNextMap, getNextString, getNextTuple, getStartCol, illustratorMarkup, isOverloaded, isProjectToEnd, isStar, processInputBag, setColumn, setColumns, setOverloaded, setProjectToEnd, setResultSingleTupleBag, setStar, supportsMultipleInputs, supportsMultipleOutputs
accumChild, containUDF, setIllustrator, toString
addOriginalLocation, addOriginalLocation, cloneHelper, clonePlans, copyAliasFrom, detachInput, getAlias, getAliasString, getIllustrator, getInputs, getLogger, getNext, getOriginalLocations, getParentPlan, getPigLogger, getReporter, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isBlocking, isEndOfAllInput, isInputAttached, processInput, setAccumEnd, setAccumStart, setAccumulative, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType, staticDataCleanup
compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, unsetProjectionMap
public PORelationToExprProject(OperatorKey k)
public PORelationToExprProject(OperatorKey k, int rp)
public PORelationToExprProject(OperatorKey k, int rp, int col)
public PORelationToExprProject(OperatorKey k, int rp, ArrayList<Integer> cols)
public void visit(PhyPlanVisitor v) throws VisitorException
Operator
visit
in class POProject
v
- Visitor to visit with.VisitorException
- if the visitor has a problem.public void reset()
PhysicalOperator
reset
in class PhysicalOperator
public Result getNextDataBag() throws ExecException
getNextDataBag
in class POProject
ExecException
public PORelationToExprProject clone() throws CloneNotSupportedException
ExpressionOperator
clone
in class POProject
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