public class POUserFunc extends ExpressionOperator
PhysicalOperator.OriginalLocation
Modifier and Type | Field and Description |
---|---|
static byte |
FINAL |
static byte |
INITIAL |
static byte |
INTERMEDIATE |
alias, illustrator, input, inputAttached, inputs, lineageTracer, mBagFactory, mTupleFactory, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType
Constructor and Description |
---|
POUserFunc(OperatorKey k,
int rp,
List<PhysicalOperator> inp) |
POUserFunc(OperatorKey k,
int rp,
List<PhysicalOperator> inp,
FuncSpec funcSpec) |
POUserFunc(OperatorKey k,
int rp,
List<PhysicalOperator> inp,
FuncSpec funcSpec,
EvalFunc func) |
accumChild, containUDF, setIllustrator, toString
addOriginalLocation, addOriginalLocation, attachInput, cloneHelper, clonePlans, copyAliasFrom, detachInput, getAlias, getAliasString, getIllustrator, getInputs, getLogger, getNext, getOriginalLocations, getParentPlan, getPigLogger, getReporter, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isBlocking, isEndOfAllInput, isInputAttached, reset, setAccumEnd, setAccumulative, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, staticDataCleanup
compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, unsetProjectionMap
public static final byte INITIAL
public static final byte INTERMEDIATE
public static final byte FINAL
public POUserFunc(OperatorKey k, int rp, List<PhysicalOperator> inp)
public POUserFunc(OperatorKey k, int rp, List<PhysicalOperator> inp, FuncSpec funcSpec)
public POUserFunc(OperatorKey k, int rp, List<PhysicalOperator> inp, FuncSpec funcSpec, EvalFunc func)
public PhysicalOperator getReferencedOperator()
public void setReferencedOperator(PhysicalOperator referencedOperator)
public void setFuncInputSchema()
public Result processInput() throws ExecException
PhysicalOperator
processInput
in class PhysicalOperator
ExecException
public Result getNextTuple() throws ExecException
getNextTuple
in class PhysicalOperator
ExecException
public Result getNextDataBag() throws ExecException
getNextDataBag
in class ExpressionOperator
ExecException
public Result getNextInteger() throws ExecException
getNextInteger
in class PhysicalOperator
ExecException
public Result getNextBoolean() throws ExecException
getNextBoolean
in class PhysicalOperator
ExecException
public Result getNextDataByteArray() throws ExecException
getNextDataByteArray
in class PhysicalOperator
ExecException
public Result getNextDouble() throws ExecException
getNextDouble
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 getNextFloat() throws ExecException
getNextFloat
in class PhysicalOperator
ExecException
public Result getNextLong() throws ExecException
getNextLong
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 void setAlgebraicFunction(byte Function) throws ExecException
ExecException
public String getInitial() throws ExecException
ExecException
public String getIntermed() throws ExecException
ExecException
public String getFinal() throws ExecException
ExecException
public Type getOriginalReturnType() throws ExecException
ExecException
public Type getReturnType()
public void finish()
public Boolean isAsynchronous()
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 FuncSpec getFuncSpec()
public void setFuncSpec(FuncSpec funcSpec)
public boolean combinable()
public POUserFunc clone() throws CloneNotSupportedException
ExpressionOperator
public List<ExpressionOperator> getChildExpressions()
getChildExpressions
in class ExpressionOperator
public void setAccumStart()
setAccumStart
in class PhysicalOperator
public void setResultType(byte resultType)
setResultType
in class PhysicalOperator
public Tuple illustratorMarkup(Object in, Object out, int eqClassIndex)
Illustrable
in
- input tupleout
- output tuple before wrapped in ExampleTupleeqClassIndex
- index into equivalence classes in illustratorpublic EvalFunc getFunc()
public String getSignature()
public void setSignature(String signature)
public void setFuncInputSchema(String signature)
signature
- public boolean needEndOfAllInputProcessing()
Copyright © 2007-2017 The Apache Software Foundation