public static class MaxWithRetractAggFunction.TimestampMaxWithRetractAggFunction extends MaxWithRetractAggFunction<TimestampData>
MaxWithRetractAggFunction.BooleanMaxWithRetractAggFunction, MaxWithRetractAggFunction.ByteMaxWithRetractAggFunction, MaxWithRetractAggFunction.DateMaxWithRetractAggFunction, MaxWithRetractAggFunction.DecimalMaxWithRetractAggFunction, MaxWithRetractAggFunction.DoubleMaxWithRetractAggFunction, MaxWithRetractAggFunction.FloatMaxWithRetractAggFunction, MaxWithRetractAggFunction.IntMaxWithRetractAggFunction, MaxWithRetractAggFunction.LongMaxWithRetractAggFunction, MaxWithRetractAggFunction.MaxWithRetractAccumulator<T>, MaxWithRetractAggFunction.ShortMaxWithRetractAggFunction, MaxWithRetractAggFunction.StringMaxWithRetractAggFunction, MaxWithRetractAggFunction.TimeMaxWithRetractAggFunction, MaxWithRetractAggFunction.TimestampMaxWithRetractAggFunction
Constructor and Description |
---|
TimestampMaxWithRetractAggFunction(int precision) |
Modifier and Type | Method and Description |
---|---|
void |
accumulate(MaxWithRetractAggFunction.MaxWithRetractAccumulator<TimestampData> acc,
TimestampData value) |
protected TypeInformation<TimestampData> |
getValueTypeInfo() |
void |
retract(MaxWithRetractAggFunction.MaxWithRetractAccumulator<TimestampData> acc,
TimestampData value) |
accumulate, createAccumulator, getAccumulatorType, getResultType, getValue, merge, resetAccumulator, retract
getKind, getRequirements, getTypeInference, requiresOver
close, functionIdentifier, open, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
isDeterministic
public TimestampMaxWithRetractAggFunction(int precision)
public void accumulate(MaxWithRetractAggFunction.MaxWithRetractAccumulator<TimestampData> acc, TimestampData value) throws Exception
Exception
public void retract(MaxWithRetractAggFunction.MaxWithRetractAccumulator<TimestampData> acc, TimestampData value) throws Exception
Exception
protected TypeInformation<TimestampData> getValueTypeInfo()
getValueTypeInfo
in class MaxWithRetractAggFunction<TimestampData>
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.