org.apache.pig.newplan.logical.relational
Class LOUnion
java.lang.Object
org.apache.pig.newplan.Operator
org.apache.pig.newplan.logical.relational.LogicalRelationalOperator
org.apache.pig.newplan.logical.relational.LOUnion
public class LOUnion
- extends LogicalRelationalOperator
Methods inherited from class org.apache.pig.newplan.logical.relational.LogicalRelationalOperator |
checkEquality, getAlias, getCustomPartitioner, getLineNumber, getRequestedParallelisam, isPinnedOption, neverUseForRealSetSchema, pinOption, resetSchema, setAlias, setCustomPartitioner, setRequestedParallelism, setSchema, toString |
LOUnion
public LOUnion(OperatorPlan plan)
LOUnion
public LOUnion(OperatorPlan plan,
boolean onSchema)
isOnSchema
public boolean isOnSchema()
getSchema
public LogicalSchema getSchema()
throws FrontendException
- Description copied from class:
LogicalRelationalOperator
- Get the schema for the output of this relational operator. This does
not merely return the schema variable. If schema is not yet set, this
will attempt to construct it. Therefore it is abstract since each
operator will need to construct its schema differently.
- Specified by:
getSchema
in class LogicalRelationalOperator
- Returns:
- the schema
- Throws:
FrontendException
accept
public void accept(PlanVisitor v)
throws FrontendException
- Description copied from class:
Operator
- Accept a visitor at this node in the graph.
- Specified by:
accept
in class Operator
- Parameters:
v
- Visitor to accept.
- Throws:
FrontendException
isEqual
public boolean isEqual(Operator other)
throws FrontendException
- Description copied from class:
Operator
- This is like a shallow equals comparison.
It returns true if two operators have equivalent properties even if they are
different objects. Here properties mean equivalent plan and equivalent name.
- Specified by:
isEqual
in class Operator
- Returns:
- true if two object have equivalent properties, else false
- Throws:
FrontendException
getInputUids
public Set<Long> getInputUids(long uid)
resetUid
public void resetUid()
- Description copied from class:
LogicalRelationalOperator
- Erase all cached uid, regenerate uid when we regenerating schema.
This process currently only used in ImplicitSplitInsert, which will
insert split and invalidate some uids in plan
- Overrides:
resetUid
in class LogicalRelationalOperator
getInputs
public List<Operator> getInputs()
getInputs
public List<Operator> getInputs(LogicalPlan plan)
setUnionOnSchema
public void setUnionOnSchema(boolean flag)
Copyright © 2012 The Apache Software Foundation