public static class LastValueWithRetractAggFunction.StringLastValueWithRetractAggFunction extends LastValueWithRetractAggFunction<BinaryString>
LastValueWithRetractAggFunction.BooleanLastValueWithRetractAggFunction, LastValueWithRetractAggFunction.ByteLastValueWithRetractAggFunction, LastValueWithRetractAggFunction.DecimalLastValueWithRetractAggFunction, LastValueWithRetractAggFunction.DoubleLastValueWithRetractAggFunction, LastValueWithRetractAggFunction.FloatLastValueWithRetractAggFunction, LastValueWithRetractAggFunction.IntLastValueWithRetractAggFunction, LastValueWithRetractAggFunction.LongLastValueWithRetractAggFunction, LastValueWithRetractAggFunction.ShortLastValueWithRetractAggFunction, LastValueWithRetractAggFunction.StringLastValueWithRetractAggFunction
Constructor and Description |
---|
StringLastValueWithRetractAggFunction() |
Modifier and Type | Method and Description |
---|---|
void |
accumulate(GenericRow acc,
BinaryString value) |
void |
accumulate(GenericRow acc,
BinaryString value,
Long order) |
protected TypeSerializer<BinaryString> |
createValueSerializer() |
TypeInformation<BinaryString> |
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 StringLastValueWithRetractAggFunction()
public TypeInformation<BinaryString> getResultType()
UserDefinedAggregateFunction
TypeInformation
of the UserDefinedAggregateFunction
's result.getResultType
in class UserDefinedAggregateFunction<BinaryString,GenericRow>
TypeInformation
of the UserDefinedAggregateFunction
's result or
null
if the result type should be automatically inferred.public void accumulate(GenericRow acc, BinaryString value) throws Exception
Exception
public void accumulate(GenericRow acc, BinaryString value, Long order) throws Exception
Exception
protected TypeSerializer<BinaryString> createValueSerializer()
createValueSerializer
in class LastValueWithRetractAggFunction<BinaryString>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.