public class Add extends BinaryExpressionOperator
PhysicalOperator.OriginalLocationlhs, rhsalias, illustrator, input, inputAttached, inputs, lineageTracer, mBagFactory, mTupleFactory, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType| Constructor and Description |
|---|
Add(OperatorKey k) |
Add(OperatorKey k,
int rp) |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Number |
add(java.lang.Number a,
java.lang.Number b,
byte dataType) |
Add |
clone()
Make a deep copy of this operator.
|
protected Result |
genericGetNext(byte dataType) |
Result |
getNextBigDecimal() |
Result |
getNextBigInteger() |
Result |
getNextDouble() |
Result |
getNextFloat() |
Result |
getNextInteger() |
Result |
getNextLong() |
java.lang.String |
name() |
void |
visit(PhyPlanVisitor v)
Visit this node with the provided visitor.
|
cloneHelper, getChildExpressions, getLhs, getRhs, illustratorMarkup, setLhs, setRhs, supportsMultipleInputsaccumChild, containUDF, getNextDataBag, setIllustrator, supportsMultipleOutputs, toStringaddOriginalLocation, addOriginalLocation, attachInput, cloneHelper, clonePlans, copyAliasFrom, detachInput, getAlias, getAliasString, getIllustrator, getInputs, getLogger, getNext, getNextBoolean, getNextDataByteArray, getNextDateTime, getNextMap, getNextString, getNextTuple, getOriginalLocations, getParentPlan, getPigLogger, getReporter, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isBlocking, isEndOfAllInput, isInputAttached, processInput, reset, setAccumEnd, setAccumStart, setAccumulative, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType, staticDataCleanupcompareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, unsetProjectionMappublic Add(OperatorKey k)
public Add(OperatorKey k, int rp)
public void visit(PhyPlanVisitor v) throws VisitorException
Operatorvisit in class ExpressionOperatorv - Visitor to visit with.VisitorException - if the visitor has a problem.public java.lang.String name()
name in class Operator<PhyPlanVisitor>protected java.lang.Number add(java.lang.Number a,
java.lang.Number b,
byte dataType)
throws ExecException
ExecExceptionprotected Result genericGetNext(byte dataType) throws ExecException
ExecExceptionpublic Result getNextDouble() throws ExecException
getNextDouble in class PhysicalOperatorExecExceptionpublic Result getNextFloat() throws ExecException
getNextFloat in class PhysicalOperatorExecExceptionpublic Result getNextInteger() throws ExecException
getNextInteger in class PhysicalOperatorExecExceptionpublic Result getNextLong() throws ExecException
getNextLong in class PhysicalOperatorExecExceptionpublic Result getNextBigInteger() throws ExecException
getNextBigInteger in class PhysicalOperatorExecExceptionpublic Result getNextBigDecimal() throws ExecException
getNextBigDecimal in class PhysicalOperatorExecExceptionpublic Add clone() throws java.lang.CloneNotSupportedException
ExpressionOperatorclone in class ExpressionOperatorjava.lang.CloneNotSupportedExceptionDo not use the clone method directly. Operators are cloned when logical plans
are cloned using {@link LogicalPlanCloner}Copyright © 2007-2025 The Apache Software Foundation