public class LORank extends LogicalRelationalOperator
alias = RANK rel ( BY (col_ref) (ASC|DESC)? ( DENSE )? )?;
alias - output alias
RANK - operator
rel - input relation
BY - operator
col_ref - STAR or Column References or a range in the schema of rel
DENSE - dense rank means a sequential value without gasp among different tuple values.
alias, lineNum, mCustomPartitioner, mPinnedOptions, requestedParallelism, schema
Constructor and Description |
---|
LORank(OperatorPlan plan) |
LORank(OperatorPlan plan,
List<LogicalExpressionPlan> rankColPlans,
List<Boolean> ascCols) |
Modifier and Type | Method and Description |
---|---|
void |
accept(PlanVisitor v)
Accept a visitor at this node in the graph.
|
List<Boolean> |
getAscendingCol() |
List<LogicalExpressionPlan> |
getRankColPlans() |
LogicalSchema |
getSchema()
Get the schema for the output of LORank.
|
boolean |
isDenseRank()
Get if it is a dense RANK BY
|
boolean |
isEqual(Operator other)
This is like a shallow equals comparison.
|
boolean |
isRowNumber()
Get if it is a simple RANK operation.
|
void |
setAscendingCol(List<Boolean> ascCols) |
void |
setIsDenseRank(boolean isDenseRank)
Set if it is a dense RANK BY
|
void |
setIsRowNumber(boolean rowNumber)
Set if it is a simple RANK operation.
|
void |
setRankColPlan(List<LogicalExpressionPlan> rankColPlans) |
checkEquality, fixDuplicateUids, getAlias, getCustomPartitioner, getLineNumber, getRequestedParallelism, isPinnedOption, neverUseForRealSetSchema, pinOption, resetSchema, resetUid, setAlias, setCustomPartitioner, setRequestedParallelism, setSchema, toString
annotate, getAnnotation, getLocation, getName, getPlan, removeAnnotation, setLocation, setPlan
public LORank(OperatorPlan plan)
public LORank(OperatorPlan plan, List<LogicalExpressionPlan> rankColPlans, List<Boolean> ascCols)
public List<LogicalExpressionPlan> getRankColPlans()
public void setRankColPlan(List<LogicalExpressionPlan> rankColPlans)
public LogicalSchema getSchema() throws FrontendException
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 boolean isDenseRank()
public void setIsDenseRank(boolean isDenseRank)
isDenseRank
- if is dense rank or notpublic boolean isRowNumber()
public void setIsRowNumber(boolean rowNumber)
rowNumber
- if is a row number operationCopyright © 2007-2017 The Apache Software Foundation