org.apache.flink.table.planner.functions.aggfunctions

Class RankLikeAggFunctionBase

java.lang.Object

org.apache.flink.table.functions.UserDefinedFunction

org.apache.flink.table.functions.DeclarativeAggregateFunction

org.apache.flink.table.planner.functions.aggfunctions.RankLikeAggFunctionBase

All Implemented Interfaces:

Serializable, org.apache.flink.table.functions.FunctionDefinition

Direct Known Subclasses:

DenseRankAggFunction, RankAggFunction

public abstract class RankLikeAggFunctionBase
extends org.apache.flink.table.functions.DeclarativeAggregateFunction

built-in rank like aggregate function, e.g. rank, dense_rank

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.flink.table.expressions.UnresolvedReferenceExpression[]	lastValues
protected org.apache.flink.table.types.logical.LogicalType[]	orderKeyTypes
protected org.apache.flink.table.expressions.UnresolvedReferenceExpression	sequence

Constructor Summary

Constructors

Constructor and Description
RankLikeAggFunctionBase(org.apache.flink.table.types.logical.LogicalType[] orderKeyTypes)

Method Summary

Modifier and Type	Method and Description
protected org.apache.flink.table.expressions.Expression	generateInitLiteral(org.apache.flink.table.types.logical.LogicalType orderType)
org.apache.flink.table.types.DataType	getResultType()
org.apache.flink.table.expressions.Expression	getValueExpression()
org.apache.flink.table.expressions.Expression[]	mergeExpressions()
int	operandCount()
protected org.apache.flink.table.expressions.Expression	orderKeyEqualsExpression()
org.apache.flink.table.expressions.Expression[]	retractExpressions()

Methods inherited from class org.apache.flink.table.functions.DeclarativeAggregateFunction

accumulateExpressions, aggBufferAttributes, getAggBufferTypes, getKind, getTypeInference, initialValuesExpressions, mergeOperand, mergeOperands, operand, operands

Methods inherited from class org.apache.flink.table.functions.UserDefinedFunction

close, functionIdentifier, open, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.flink.table.functions.FunctionDefinition

getRequirements, isDeterministic

Field Detail

sequence

protected org.apache.flink.table.expressions.UnresolvedReferenceExpression sequence

lastValues

protected org.apache.flink.table.expressions.UnresolvedReferenceExpression[] lastValues

orderKeyTypes

protected org.apache.flink.table.types.logical.LogicalType[] orderKeyTypes

Constructor Detail

RankLikeAggFunctionBase

public RankLikeAggFunctionBase(org.apache.flink.table.types.logical.LogicalType[] orderKeyTypes)

Method Detail

operandCount

public int operandCount()

Specified by:

operandCount in class org.apache.flink.table.functions.DeclarativeAggregateFunction

getResultType

public org.apache.flink.table.types.DataType getResultType()

Specified by:

getResultType in class org.apache.flink.table.functions.DeclarativeAggregateFunction

retractExpressions

public org.apache.flink.table.expressions.Expression[] retractExpressions()

Specified by:

retractExpressions in class org.apache.flink.table.functions.DeclarativeAggregateFunction

mergeExpressions

public org.apache.flink.table.expressions.Expression[] mergeExpressions()

Specified by:

mergeExpressions in class org.apache.flink.table.functions.DeclarativeAggregateFunction

getValueExpression

public org.apache.flink.table.expressions.Expression getValueExpression()

Specified by:

getValueExpression in class org.apache.flink.table.functions.DeclarativeAggregateFunction

orderKeyEqualsExpression

protected org.apache.flink.table.expressions.Expression orderKeyEqualsExpression()

generateInitLiteral

protected org.apache.flink.table.expressions.Expression generateInitLiteral(org.apache.flink.table.types.logical.LogicalType orderType)