public class LOGenerate extends LogicalRelationalOperator
alias, lineNum, mCustomPartitioner, mPinnedOptions, requestedParallelism, schema
Constructor and Description |
---|
LOGenerate(OperatorPlan plan) |
LOGenerate(OperatorPlan plan,
List<LogicalExpressionPlan> ps,
boolean[] flatten) |
Modifier and Type | Method and Description |
---|---|
void |
accept(PlanVisitor v)
Accept a visitor at this node in the graph.
|
List<LogicalSchema> |
getExpSchemas() |
boolean[] |
getFlattenFlags() |
List<LogicalExpressionPlan> |
getOutputPlans() |
List<LogicalSchema> |
getOutputPlanSchemas()
Get the output schema corresponding to each input expression plan
|
LogicalSchema |
getSchema()
Get the schema for the output of this relational operator.
|
List<LogicalSchema> |
getUidOnlySchemas() |
List<LogicalSchema> |
getUserDefinedSchema() |
boolean |
isEqual(Operator other)
This is like a shallow equals comparison.
|
void |
resetSchema()
Reset the schema to null so that the next time getSchema is called
the schema will be regenerated from scratch.
|
void |
resetUid()
Erase all cached uid, regenerate uid when we regenerating schema.
|
void |
setFlattenFlags(boolean[] flatten) |
void |
setOutputPlans(List<LogicalExpressionPlan> plans) |
void |
setOutputPlanSchemas(List<LogicalSchema> outputPlanSchemas) |
void |
setUidOnlySchemas(List<LogicalSchema> uidOnlySchemas) |
void |
setUserDefinedSchema(List<LogicalSchema> userDefinedSchema) |
String |
toString() |
checkEquality, fixDuplicateUids, getAlias, getCustomPartitioner, getLineNumber, getRequestedParallelism, isPinnedOption, neverUseForRealSetSchema, pinOption, setAlias, setCustomPartitioner, setRequestedParallelism, setSchema
annotate, getAnnotation, getLocation, getName, getPlan, removeAnnotation, setLocation, setPlan
public LOGenerate(OperatorPlan plan, List<LogicalExpressionPlan> ps, boolean[] flatten)
public LOGenerate(OperatorPlan plan)
public void setOutputPlans(List<LogicalExpressionPlan> plans)
public LogicalSchema getSchema() throws FrontendException
LogicalRelationalOperator
getSchema
in class LogicalRelationalOperator
FrontendException
public List<LogicalExpressionPlan> getOutputPlans()
public boolean[] getFlattenFlags()
public void setFlattenFlags(boolean[] flatten)
public boolean isEqual(Operator other) throws FrontendException
Operator
isEqual
in class Operator
FrontendException
public void accept(PlanVisitor v) throws FrontendException
Operator
accept
in class Operator
v
- Visitor to accept.FrontendException
public String toString()
toString
in class LogicalRelationalOperator
public List<LogicalSchema> getUserDefinedSchema()
public void setUserDefinedSchema(List<LogicalSchema> userDefinedSchema)
public List<LogicalSchema> getOutputPlanSchemas()
public void setOutputPlanSchemas(List<LogicalSchema> outputPlanSchemas)
public List<LogicalSchema> getUidOnlySchemas()
public void setUidOnlySchemas(List<LogicalSchema> uidOnlySchemas)
public void resetUid()
LogicalRelationalOperator
resetUid
in class LogicalRelationalOperator
public void resetSchema()
LogicalRelationalOperator
resetSchema
in class LogicalRelationalOperator
public List<LogicalSchema> getExpSchemas()
Copyright © 2007-2017 The Apache Software Foundation