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

类 ListAggFunction

java.lang.Object

org.apache.flink.table.functions.UserDefinedFunction

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

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

所有已实现的接口:

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

public class ListAggFunction
extends DeclarativeAggregateFunction

built-in listagg aggregate function.

另请参阅:

序列化表格

构造器概要

构造器

构造器和说明
ListAggFunction(int operandCount)

方法概要

限定符和类型	方法和说明
org.apache.flink.table.expressions.Expression[]	accumulateExpressions() Expressions for accumulating the mutable aggregation buffer based on an input row.
org.apache.flink.table.expressions.UnresolvedReferenceExpression[]	aggBufferAttributes() All fields of the aggregate buffer.
org.apache.flink.table.types.DataType[]	getAggBufferTypes() All types of the aggregate buffer.
org.apache.flink.table.types.DataType	getResultType() The result type of the function.
org.apache.flink.table.expressions.Expression	getValueExpression() An expression which returns the final value for this aggregate function.
org.apache.flink.table.expressions.Expression[]	initialValuesExpressions() Expressions for initializing empty aggregation buffers.
org.apache.flink.table.expressions.Expression[]	mergeExpressions() A sequence of expressions for merging two aggregation buffers together.
int	operandCount() How many operands your function will deal with.
org.apache.flink.table.expressions.Expression[]	retractExpressions() Expressions for retracting the mutable aggregation buffer based on an input row.

从类继承的方法 org.apache.flink.table.planner.functions.aggfunctions.DeclarativeAggregateFunction

getKind, getTypeInference, mergeOperand, mergeOperands, operand, operands

从类继承的方法 org.apache.flink.table.functions.UserDefinedFunction

close, functionIdentifier, open, toString

从类继承的方法 java.lang.Object

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

从接口继承的方法 org.apache.flink.table.functions.FunctionDefinition

getRequirements, isDeterministic

构造器详细资料

ListAggFunction

public ListAggFunction(int operandCount)

方法详细资料

operandCount

public int operandCount()

从类复制的说明: DeclarativeAggregateFunction

How many operands your function will deal with.

指定者:

operandCount 在类中 DeclarativeAggregateFunction

aggBufferAttributes

public org.apache.flink.table.expressions.UnresolvedReferenceExpression[] aggBufferAttributes()

从类复制的说明: DeclarativeAggregateFunction

All fields of the aggregate buffer.

指定者:

aggBufferAttributes 在类中 DeclarativeAggregateFunction

getAggBufferTypes

public org.apache.flink.table.types.DataType[] getAggBufferTypes()

从类复制的说明: DeclarativeAggregateFunction

All types of the aggregate buffer.

指定者:

getAggBufferTypes 在类中 DeclarativeAggregateFunction

getResultType

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

从类复制的说明: DeclarativeAggregateFunction

The result type of the function.

指定者:

getResultType 在类中 DeclarativeAggregateFunction

initialValuesExpressions

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

从类复制的说明: DeclarativeAggregateFunction

Expressions for initializing empty aggregation buffers.

指定者:

initialValuesExpressions 在类中 DeclarativeAggregateFunction

accumulateExpressions

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

从类复制的说明: DeclarativeAggregateFunction

Expressions for accumulating the mutable aggregation buffer based on an input row.

指定者:

accumulateExpressions 在类中 DeclarativeAggregateFunction

retractExpressions

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

从类复制的说明: DeclarativeAggregateFunction

Expressions for retracting the mutable aggregation buffer based on an input row.

指定者:

retractExpressions 在类中 DeclarativeAggregateFunction

mergeExpressions

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

从类复制的说明: DeclarativeAggregateFunction

A sequence of expressions for merging two aggregation buffers together. When defining these expressions, you can use the syntax attributeName and mergeOperand(attributeName) to refer to the attributes corresponding to each of the buffers being merged.

指定者:

mergeExpressions 在类中 DeclarativeAggregateFunction

getValueExpression

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

从类复制的说明: DeclarativeAggregateFunction

An expression which returns the final value for this aggregate function.

指定者:

getValueExpression 在类中 DeclarativeAggregateFunction