|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.pig.impl.plan.Operator<PhyPlanVisitor>
org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ExpressionOperator
public abstract class ExpressionOperator
A base class for all types of expressions. All expression operators must extend this class.
Nested Class Summary |
---|
Nested classes/interfaces inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator |
---|
PhysicalOperator.OriginalLocation |
Field Summary |
---|
Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator |
---|
alias, dummyBag, dummyBool, dummyDateTime, dummyDBA, dummyDouble, dummyFloat, dummyInt, dummyLong, dummyMap, dummyString, dummyTuple, illustrator, input, inputAttached, inputs, lineageTracer, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, resultType |
Fields inherited from class org.apache.pig.impl.plan.Operator |
---|
mKey |
Constructor Summary | |
---|---|
ExpressionOperator(OperatorKey k)
|
|
ExpressionOperator(OperatorKey k,
int rp)
|
Method Summary | |
---|---|
protected Result |
accumChild(List<ExpressionOperator> child,
Boolean b)
Drive all the UDFs in accumulative mode |
protected Result |
accumChild(List<ExpressionOperator> child,
DataBag db)
Drive all the UDFs in accumulative mode |
protected Result |
accumChild(List<ExpressionOperator> child,
DataByteArray dba)
Drive all the UDFs in accumulative mode |
protected Result |
accumChild(List<ExpressionOperator> child,
org.joda.time.DateTime dt)
Drive all the UDFs in accumulative mode |
protected Result |
accumChild(List<ExpressionOperator> child,
Double d)
Drive all the UDFs in accumulative mode |
protected Result |
accumChild(List<ExpressionOperator> child,
Float f)
Drive all the UDFs in accumulative mode |
protected Result |
accumChild(List<ExpressionOperator> child,
Integer v)
Drive all the UDFs in accumulative mode |
protected Result |
accumChild(List<ExpressionOperator> child,
Long l)
Drive all the UDFs in accumulative mode |
protected Result |
accumChild(List<ExpressionOperator> child,
Map map)
Drive all the UDFs in accumulative mode |
protected Result |
accumChild(List<ExpressionOperator> child,
Object o,
byte dataType)
Drive all the UDFs in accumulative mode |
protected Result |
accumChild(List<ExpressionOperator> child,
String s)
Drive all the UDFs in accumulative mode |
protected Result |
accumChild(List<ExpressionOperator> child,
Tuple t)
Drive all the UDFs in accumulative mode |
ExpressionOperator |
clone()
Make a deep copy of this operator. |
boolean |
containUDF()
check whether this expression contains any UDF this is called if reducer is run as accumulative mode in this case, all UDFs must be called |
protected abstract List<ExpressionOperator> |
getChildExpressions()
Get the sub-expressions of this expression. |
Result |
getNext(DataBag db)
|
void |
setIllustrator(Illustrator illustrator)
|
boolean |
supportsMultipleOutputs()
Indicates whether this operator supports multiple outputs. |
abstract void |
visit(PhyPlanVisitor v)
Visit this node with the provided visitor. |
Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator |
---|
addOriginalLocation, addOriginalLocation, attachInput, cloneHelper, detachInput, getAlias, getAliasString, getDummy, getIllustrator, getInputs, getLogger, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getOriginalLocations, getPigLogger, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isBlocking, isInputAttached, processInput, reset, setAccumEnd, setAccumStart, setAccumulative, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType |
Methods inherited from class org.apache.pig.impl.plan.Operator |
---|
compareTo, equals, getOperatorKey, getProjectionMap, hashCode, name, regenerateProjectionMap, rewire, supportsMultipleInputs, toString, unsetProjectionMap |
Methods inherited from class java.lang.Object |
---|
finalize, getClass, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.apache.pig.pen.Illustrable |
---|
illustratorMarkup |
Constructor Detail |
---|
public ExpressionOperator(OperatorKey k)
public ExpressionOperator(OperatorKey k, int rp)
Method Detail |
---|
public void setIllustrator(Illustrator illustrator)
setIllustrator
in interface Illustrable
setIllustrator
in class PhysicalOperator
public boolean supportsMultipleOutputs()
Operator
supportsMultipleOutputs
in class Operator<PhyPlanVisitor>
public Result getNext(DataBag db) throws ExecException
getNext
in class PhysicalOperator
ExecException
public abstract void visit(PhyPlanVisitor v) throws VisitorException
Operator
visit
in class PhysicalOperator
v
- Visitor to visit with.
VisitorException
- if the visitor has a problem.public ExpressionOperator clone() throws CloneNotSupportedException
clone
in class PhysicalOperator
CloneNotSupportedException
Do not use the clone method directly. Operators are cloned when logical plans
are cloned using {@link LogicalPlanCloner}
protected abstract List<ExpressionOperator> getChildExpressions()
public boolean containUDF()
protected Result accumChild(List<ExpressionOperator> child, Object o, byte dataType) throws ExecException
ExecException
protected Result accumChild(List<ExpressionOperator> child, Double d) throws ExecException
ExecException
protected Result accumChild(List<ExpressionOperator> child, Integer v) throws ExecException
ExecException
protected Result accumChild(List<ExpressionOperator> child, Long l) throws ExecException
ExecException
protected Result accumChild(List<ExpressionOperator> child, Float f) throws ExecException
ExecException
protected Result accumChild(List<ExpressionOperator> child, Boolean b) throws ExecException
ExecException
protected Result accumChild(List<ExpressionOperator> child, org.joda.time.DateTime dt) throws ExecException
ExecException
protected Result accumChild(List<ExpressionOperator> child, String s) throws ExecException
ExecException
protected Result accumChild(List<ExpressionOperator> child, DataByteArray dba) throws ExecException
ExecException
protected Result accumChild(List<ExpressionOperator> child, Map map) throws ExecException
ExecException
protected Result accumChild(List<ExpressionOperator> child, Tuple t) throws ExecException
ExecException
protected Result accumChild(List<ExpressionOperator> child, DataBag db) throws ExecException
ExecException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |