org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators
Class POMapLookUp
java.lang.Object
org.apache.pig.impl.plan.Operator<PhyPlanVisitor>
org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ExpressionOperator
org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POMapLookUp
- All Implemented Interfaces:
- Serializable, Cloneable, Comparable<Operator>, Illustrable
public class POMapLookUp
- extends ExpressionOperator
- See Also:
- Serialized Form
Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator |
alias, dummyBag, dummyBool, 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 |
Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ExpressionOperator |
accumChild, accumChild, accumChild, accumChild, accumChild, accumChild, accumChild, accumChild, accumChild, accumChild, accumChild, containUDF, setIllustrator, supportsMultipleOutputs |
Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator |
attachInput, cloneHelper, detachInput, getAlias, getAliasString, getDummy, getIllustrator, getInputs, getLogger, getNext, getPigLogger, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isBlocking, isInputAttached, reset, setAccumEnd, setAccumStart, setAccumulative, setAlias, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType |
POMapLookUp
public POMapLookUp(OperatorKey k)
POMapLookUp
public POMapLookUp(OperatorKey k,
int rp)
POMapLookUp
public POMapLookUp(OperatorKey k,
int rp,
String key)
setLookUpKey
public void setLookUpKey(String key)
getLookUpKey
public String getLookUpKey()
visit
public void visit(PhyPlanVisitor v)
throws VisitorException
- Description copied from class:
Operator
- Visit this node with the provided visitor. This should only be called by
the visitor class itself, never directly.
- Specified by:
visit
in class ExpressionOperator
- Parameters:
v
- Visitor to visit with.
- Throws:
VisitorException
- if the visitor has a problem.
name
public String name()
- Specified by:
name
in class Operator<PhyPlanVisitor>
supportsMultipleInputs
public boolean supportsMultipleInputs()
- Description copied from class:
Operator
- Indicates whether this operator supports multiple inputs.
- Specified by:
supportsMultipleInputs
in class Operator<PhyPlanVisitor>
- Returns:
- true if it does, otherwise false.
processInput
public Result processInput()
throws ExecException
- Description copied from class:
PhysicalOperator
- A generic method for parsing input that either returns the attached input
if it exists or fetches it from its predecessor. If special processing is
required, this method should be overridden.
- Overrides:
processInput
in class PhysicalOperator
- Returns:
- The Result object that results from processing the input
- Throws:
ExecException
getNext
public Result getNext(Boolean b)
throws ExecException
- Overrides:
getNext
in class PhysicalOperator
- Throws:
ExecException
getNext
public Result getNext(DataBag db)
throws ExecException
- Overrides:
getNext
in class ExpressionOperator
- Throws:
ExecException
getNext
public Result getNext(DataByteArray ba)
throws ExecException
- Overrides:
getNext
in class PhysicalOperator
- Throws:
ExecException
getNext
public Result getNext(Double d)
throws ExecException
- Overrides:
getNext
in class PhysicalOperator
- Throws:
ExecException
getNext
public Result getNext(Float f)
throws ExecException
- Overrides:
getNext
in class PhysicalOperator
- Throws:
ExecException
getNext
public Result getNext(Integer i)
throws ExecException
- Overrides:
getNext
in class PhysicalOperator
- Throws:
ExecException
getNext
public Result getNext(Long l)
throws ExecException
- Overrides:
getNext
in class PhysicalOperator
- Throws:
ExecException
getNext
public Result getNext(Map m)
throws ExecException
- Overrides:
getNext
in class PhysicalOperator
- Throws:
ExecException
getNext
public Result getNext(String s)
throws ExecException
- Overrides:
getNext
in class PhysicalOperator
- Throws:
ExecException
getNext
public Result getNext(Tuple t)
throws ExecException
- Overrides:
getNext
in class PhysicalOperator
- Throws:
ExecException
clone
public POMapLookUp clone()
throws CloneNotSupportedException
- Description copied from class:
ExpressionOperator
- Make a deep copy of this operator. This is declared here to make it
possible to call clone on ExpressionOperators.
- Overrides:
clone
in class ExpressionOperator
- Throws:
CloneNotSupportedException
- See Also:
Do not use the clone method directly. Operators are cloned when logical plans
are cloned using {@link LogicalPlanCloner}
getChildExpressions
public List<ExpressionOperator> getChildExpressions()
- Description copied from class:
ExpressionOperator
- Get the sub-expressions of this expression.
This is called if reducer is run as accumulative mode, all the child
expression must be called if they have any UDF to drive the UDF.accumulate()
- Specified by:
getChildExpressions
in class ExpressionOperator
illustratorMarkup
public Tuple illustratorMarkup(Object in,
Object out,
int eqClassIndex)
- Description copied from interface:
Illustrable
- input tuple mark up to be illustrate-able
- Parameters:
in
- input tupleout
- output tuple before wrapped in ExampleTupleeqClassIndex
- index into equivalence classes in illustrator
- Returns:
- tuple
Copyright © ${year} The Apache Software Foundation