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

Class FirstValueAggFunction.StringFirstValueAggFunction

java.lang.Object

org.apache.flink.table.functions.UserDefinedFunction

org.apache.flink.table.functions.UserDefinedAggregateFunction<T,ACC>

org.apache.flink.table.functions.AggregateFunction<T,GenericRowData>

org.apache.flink.table.planner.functions.aggfunctions.FirstValueAggFunction<StringData>

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

All Implemented Interfaces:

Serializable, FunctionDefinition

Enclosing class:

FirstValueAggFunction<T>

public static class FirstValueAggFunction.StringFirstValueAggFunction
extends FirstValueAggFunction<StringData>

Built-in String FirstValue aggregate function.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.table.planner.functions.aggfunctions.FirstValueAggFunction

FirstValueAggFunction.BooleanFirstValueAggFunction, FirstValueAggFunction.ByteFirstValueAggFunction, FirstValueAggFunction.DecimalFirstValueAggFunction, FirstValueAggFunction.DoubleFirstValueAggFunction, FirstValueAggFunction.FloatFirstValueAggFunction, FirstValueAggFunction.IntFirstValueAggFunction, FirstValueAggFunction.LongFirstValueAggFunction, FirstValueAggFunction.ShortFirstValueAggFunction, FirstValueAggFunction.StringFirstValueAggFunction

Constructor Summary

Constructors

Constructor and Description
StringFirstValueAggFunction()

Method Summary

Modifier and Type	Method and Description
void	accumulate(GenericRowData acc, StringData value)
void	accumulate(GenericRowData acc, StringData value, Long order)
TypeInformation<StringData>	getResultType() Returns the TypeInformation of the UserDefinedAggregateFunction's result.

Methods inherited from class org.apache.flink.table.planner.functions.aggfunctions.FirstValueAggFunction

accumulate, accumulate, createAccumulator, getAccumulatorType, getValue, isDeterministic, resetAccumulator

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

getKind, getRequirements, getTypeInference, requiresOver

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

Constructor Detail

StringFirstValueAggFunction

public StringFirstValueAggFunction()

Method Detail

getResultType

public TypeInformation<StringData> getResultType()

Description copied from class: UserDefinedAggregateFunction

Returns the TypeInformation of the UserDefinedAggregateFunction's result.

Overrides:

getResultType in class UserDefinedAggregateFunction<StringData,GenericRowData>

Returns:

The TypeInformation of the UserDefinedAggregateFunction's result or null if the result type should be automatically inferred.

accumulate

public void accumulate(GenericRowData acc,
                       StringData value)

accumulate

public void accumulate(GenericRowData acc,
                       StringData value,
                       Long order)