public static class FirstValueWithRetractAggFunction.DecimalFirstValueWithRetractAggFunction extends FirstValueWithRetractAggFunction<Decimal>
FirstValueWithRetractAggFunction.BooleanFirstValueWithRetractAggFunction, FirstValueWithRetractAggFunction.ByteFirstValueWithRetractAggFunction, FirstValueWithRetractAggFunction.DecimalFirstValueWithRetractAggFunction, FirstValueWithRetractAggFunction.DoubleFirstValueWithRetractAggFunction, FirstValueWithRetractAggFunction.FloatFirstValueWithRetractAggFunction, FirstValueWithRetractAggFunction.IntFirstValueWithRetractAggFunction, FirstValueWithRetractAggFunction.LongFirstValueWithRetractAggFunction, FirstValueWithRetractAggFunction.ShortFirstValueWithRetractAggFunction, FirstValueWithRetractAggFunction.StringFirstValueWithRetractAggFunction
Constructor and Description |
---|
DecimalFirstValueWithRetractAggFunction(DecimalTypeInfo decimalTypeInfo) |
Modifier and Type | Method and Description |
---|---|
void |
accumulate(GenericRow acc,
Decimal value) |
void |
accumulate(GenericRow acc,
Decimal value,
Long order) |
protected TypeSerializer<Decimal> |
createValueSerializer() |
TypeInformation<Decimal> |
getResultType()
Returns the
TypeInformation of the UserDefinedAggregateFunction 's result. |
accumulate, accumulate, createAccumulator, getAccumulatorType, getValue, resetAccumulator, retract, retract
getKind, getRequirements, requiresOver
close, functionIdentifier, open, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
isDeterministic
public DecimalFirstValueWithRetractAggFunction(DecimalTypeInfo decimalTypeInfo)
public void accumulate(GenericRow acc, Decimal value) throws Exception
Exception
public void accumulate(GenericRow acc, Decimal value, Long order) throws Exception
Exception
public TypeInformation<Decimal> getResultType()
UserDefinedAggregateFunction
TypeInformation
of the UserDefinedAggregateFunction
's result.getResultType
in class UserDefinedAggregateFunction<Decimal,GenericRow>
TypeInformation
of the UserDefinedAggregateFunction
's result or
null
if the result type should be automatically inferred.protected TypeSerializer<Decimal> createValueSerializer()
createValueSerializer
in class FirstValueWithRetractAggFunction<Decimal>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.