public static class LastValueWithRetractAggFunction.DecimalLastValueWithRetractAggFunction extends LastValueWithRetractAggFunction<DecimalData>
LastValueWithRetractAggFunction.BooleanLastValueWithRetractAggFunction, LastValueWithRetractAggFunction.ByteLastValueWithRetractAggFunction, LastValueWithRetractAggFunction.DecimalLastValueWithRetractAggFunction, LastValueWithRetractAggFunction.DoubleLastValueWithRetractAggFunction, LastValueWithRetractAggFunction.FloatLastValueWithRetractAggFunction, LastValueWithRetractAggFunction.IntLastValueWithRetractAggFunction, LastValueWithRetractAggFunction.LongLastValueWithRetractAggFunction, LastValueWithRetractAggFunction.ShortLastValueWithRetractAggFunction, LastValueWithRetractAggFunction.StringLastValueWithRetractAggFunction
Constructor and Description |
---|
DecimalLastValueWithRetractAggFunction(DecimalDataTypeInfo decimalTypeInfo) |
Modifier and Type | Method and Description |
---|---|
void |
accumulate(GenericRowData acc,
DecimalData value) |
void |
accumulate(GenericRowData acc,
DecimalData value,
Long order) |
protected TypeSerializer<DecimalData> |
createValueSerializer() |
TypeInformation<DecimalData> |
getResultType()
Returns the
TypeInformation of the UserDefinedAggregateFunction 's result. |
accumulate, accumulate, createAccumulator, getAccumulatorType, getValue, resetAccumulator, retract, retract
getKind, getRequirements, getTypeInference, requiresOver
close, functionIdentifier, open, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
isDeterministic
public DecimalLastValueWithRetractAggFunction(DecimalDataTypeInfo decimalTypeInfo)
public void accumulate(GenericRowData acc, DecimalData value) throws Exception
Exception
public void accumulate(GenericRowData acc, DecimalData value, Long order) throws Exception
Exception
public TypeInformation<DecimalData> getResultType()
UserDefinedAggregateFunction
TypeInformation
of the UserDefinedAggregateFunction
's result.getResultType
in class UserDefinedAggregateFunction<DecimalData,GenericRowData>
TypeInformation
of the UserDefinedAggregateFunction
's result or
null
if the result type should be automatically inferred.protected TypeSerializer<DecimalData> createValueSerializer()
createValueSerializer
in class LastValueWithRetractAggFunction<DecimalData>
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.