org.apache.pig.newplan.logical.relational
Class LOSplitOutput
java.lang.Object
org.apache.pig.newplan.Operator
org.apache.pig.newplan.logical.relational.LogicalRelationalOperator
org.apache.pig.newplan.logical.relational.LOSplitOutput
public class LOSplitOutput
- 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 |
LOSplitOutput
public LOSplitOutput(LogicalPlan plan)
LOSplitOutput
public LOSplitOutput(LogicalPlan plan,
LogicalExpressionPlan filterPlan)
getFilterPlan
public LogicalExpressionPlan getFilterPlan()
setFilterPlan
public void setFilterPlan(LogicalExpressionPlan filterPlan)
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
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
getInputUids
public long getInputUids(long uid)
Copyright © 2012 The Apache Software Foundation