public class POProject extends ExpressionOperator
PhysicalOperator.OriginalLocation
Modifier and Type | Field and Description |
---|---|
protected ArrayList<Integer> |
columns |
protected boolean |
isProjectToEnd |
protected boolean |
overloaded |
protected int |
startCol |
alias, illustrator, input, inputAttached, inputs, lineageTracer, mBagFactory, mTupleFactory, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType
Constructor and Description |
---|
POProject(OperatorKey k) |
POProject(OperatorKey k,
int rp) |
POProject(OperatorKey k,
int rp,
ArrayList<Integer> cols) |
POProject(OperatorKey k,
int rp,
int col) |
Modifier and Type | Method and Description |
---|---|
void |
attachInput(Tuple t)
Overridden since the attachment of the new input
should cause the old processing to end.
|
POProject |
clone()
Make a deep copy of this operator.
|
protected Result |
consumeInputBag(Result input) |
List<ExpressionOperator> |
getChildExpressions()
Get the sub-expressions of this expression.
|
int |
getColumn() |
ArrayList<Integer> |
getColumns() |
Result |
getNext()
Fetches the input tuple and returns the requested
column
|
Result |
getNextBigDecimal() |
Result |
getNextBigInteger() |
Result |
getNextBoolean() |
Result |
getNextDataBag() |
Result |
getNextDataByteArray() |
Result |
getNextDateTime() |
Result |
getNextDouble() |
Result |
getNextFloat() |
Result |
getNextInteger() |
Result |
getNextLong() |
Result |
getNextMap() |
Result |
getNextString() |
Result |
getNextTuple()
Asked for Tuples.
|
int |
getStartCol() |
Tuple |
illustratorMarkup(Object in,
Object out,
int eqClassIndex)
input tuple mark up to be illustrate-able
|
boolean |
isOverloaded() |
boolean |
isProjectToEnd() |
boolean |
isStar() |
String |
name() |
protected Result |
processInputBag() |
void |
setColumn(int col) |
void |
setColumns(ArrayList<Integer> cols) |
void |
setOverloaded(boolean overloaded) |
void |
setProjectToEnd(int startCol) |
void |
setResultSingleTupleBag(boolean resultSingleTupleBag) |
void |
setStar(boolean star) |
boolean |
supportsMultipleInputs()
Indicates whether this operator supports multiple inputs.
|
boolean |
supportsMultipleOutputs()
Indicates whether this operator supports multiple outputs.
|
void |
visit(PhyPlanVisitor v)
Visit this node with the provided visitor.
|
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, reset, setAccumEnd, setAccumStart, setAccumulative, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType, staticDataCleanup
compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, unsetProjectionMap
protected boolean overloaded
protected boolean isProjectToEnd
protected int startCol
public POProject(OperatorKey k)
public POProject(OperatorKey k, int rp)
public POProject(OperatorKey k, int rp, int col)
public POProject(OperatorKey k, int rp, ArrayList<Integer> cols)
public void setProjectToEnd(int startCol)
public String name()
name
in class Operator<PhyPlanVisitor>
public boolean supportsMultipleInputs()
Operator
supportsMultipleInputs
in class Operator<PhyPlanVisitor>
public boolean supportsMultipleOutputs()
Operator
supportsMultipleOutputs
in class ExpressionOperator
public void visit(PhyPlanVisitor v) throws VisitorException
Operator
visit
in class ExpressionOperator
v
- Visitor to visit with.VisitorException
- if the visitor has a problem.public void attachInput(Tuple t)
attachInput
in class PhysicalOperator
t
- -
The tuple that should be used as inputpublic Result getNext() throws ExecException
ExecException
public Result getNextDataBag() throws ExecException
getNextDataBag
in class ExpressionOperator
ExecException
protected Result consumeInputBag(Result input) throws ExecException
input
- ExecException
public Result getNextDataByteArray() throws ExecException
getNextDataByteArray
in class PhysicalOperator
ExecException
public Result getNextDouble() throws ExecException
getNextDouble
in class PhysicalOperator
ExecException
public Result getNextFloat() throws ExecException
getNextFloat
in class PhysicalOperator
ExecException
public Result getNextInteger() throws ExecException
getNextInteger
in class PhysicalOperator
ExecException
public Result getNextLong() throws ExecException
getNextLong
in class PhysicalOperator
ExecException
public Result getNextBoolean() throws ExecException
getNextBoolean
in class PhysicalOperator
ExecException
public Result getNextDateTime() throws ExecException
getNextDateTime
in class PhysicalOperator
ExecException
public Result getNextMap() throws ExecException
getNextMap
in class PhysicalOperator
ExecException
public Result getNextString() throws ExecException
getNextString
in class PhysicalOperator
ExecException
public Result getNextBigInteger() throws ExecException
getNextBigInteger
in class PhysicalOperator
ExecException
public Result getNextBigDecimal() throws ExecException
getNextBigDecimal
in class PhysicalOperator
ExecException
public Result getNextTuple() throws ExecException
getNextTuple
in class PhysicalOperator
ExecException
public int getColumn() throws ExecException
ExecException
public int getStartCol()
public void setColumn(int col)
public boolean isOverloaded()
public void setOverloaded(boolean overloaded)
public boolean isStar()
public boolean isProjectToEnd()
public void setStar(boolean star)
public POProject clone() throws CloneNotSupportedException
ExpressionOperator
protected Result processInputBag() throws ExecException
ExecException
public void setResultSingleTupleBag(boolean resultSingleTupleBag)
public List<ExpressionOperator> getChildExpressions()
ExpressionOperator
getChildExpressions
in class ExpressionOperator
public Tuple illustratorMarkup(Object in, Object out, int eqClassIndex)
Illustrable
in
- input tupleout
- output tuple before wrapped in ExampleTupleeqClassIndex
- index into equivalence classes in illustratorCopyright © 2007-2017 The Apache Software Foundation