public class LOCogroup extends LogicalRelationalOperator
Modifier and Type | Class and Description |
---|---|
static class |
LOCogroup.GROUPTYPE
Enum for the type of group
|
Modifier and Type | Field and Description |
---|---|
static Integer |
OPTION_GROUPTYPE
static constant to refer to the option of selecting a group type
|
alias, lineNum, mCustomPartitioner, mPinnedOptions, requestedParallelism, schema
Constructor and Description |
---|
LOCogroup(LogicalPlan plan)
Constructor for use in defining rule patterns
|
LOCogroup(OperatorPlan plan,
MultiMap<Integer,LogicalExpressionPlan> expressionPlans,
boolean[] isInner) |
LOCogroup(OperatorPlan plan,
MultiMap<Integer,LogicalExpressionPlan> expressionPlans,
LOCogroup.GROUPTYPE groupType,
boolean[] isInner) |
Modifier and Type | Method and Description |
---|---|
void |
accept(PlanVisitor v)
Accept a visitor at this node in the graph.
|
MultiMap<Integer,LogicalExpressionPlan> |
getExpressionPlans() |
Map<Integer,Long> |
getGeneratedInputUids()
Returns an Unmodifiable Map of Input Number to Uid
|
LOCogroup.GROUPTYPE |
getGroupType() |
boolean[] |
getInner() |
List<Operator> |
getInputs(LogicalPlan plan) |
LogicalSchema |
getSchema()
Get the schema for the output of this relational operator.
|
boolean |
isEqual(Operator other)
This is like a shallow equals comparison.
|
void |
resetGroupType() |
void |
resetUid()
Erase all cached uid, regenerate uid when we regenerating schema.
|
void |
setExpressionPlans(MultiMap<Integer,LogicalExpressionPlan> plans) |
void |
setGroupType(LOCogroup.GROUPTYPE gt) |
void |
setInnerFlags(boolean[] flags) |
checkEquality, fixDuplicateUids, getAlias, getCustomPartitioner, getLineNumber, getRequestedParallelism, isPinnedOption, neverUseForRealSetSchema, pinOption, resetSchema, setAlias, setCustomPartitioner, setRequestedParallelism, setSchema, toString
annotate, getAnnotation, getLocation, getName, getPlan, removeAnnotation, setLocation, setPlan
public static final Integer OPTION_GROUPTYPE
public LOCogroup(LogicalPlan plan)
plan
- public LOCogroup(OperatorPlan plan, MultiMap<Integer,LogicalExpressionPlan> expressionPlans, boolean[] isInner)
public LOCogroup(OperatorPlan plan, MultiMap<Integer,LogicalExpressionPlan> expressionPlans, LOCogroup.GROUPTYPE groupType, boolean[] isInner)
public LogicalSchema getSchema() throws FrontendException
LogicalRelationalOperator
getSchema
in class LogicalRelationalOperator
FrontendException
public void accept(PlanVisitor v) throws FrontendException
Operator
accept
in class Operator
v
- Visitor to accept.FrontendException
public boolean isEqual(Operator other) throws FrontendException
Operator
isEqual
in class Operator
FrontendException
public LOCogroup.GROUPTYPE getGroupType()
public void resetGroupType()
public Map<Integer,Long> getGeneratedInputUids()
public MultiMap<Integer,LogicalExpressionPlan> getExpressionPlans()
public void setExpressionPlans(MultiMap<Integer,LogicalExpressionPlan> plans)
public void setGroupType(LOCogroup.GROUPTYPE gt)
public void setInnerFlags(boolean[] flags)
public boolean[] getInner()
public void resetUid()
LogicalRelationalOperator
resetUid
in class LogicalRelationalOperator
public List<Operator> getInputs(LogicalPlan plan)
Copyright © 2007-2017 The Apache Software Foundation