public abstract class MaxWithRetractAggFunction<T extends Comparable> extends AggregateFunction<T,MaxWithRetractAggFunction.MaxWithRetractAccumulator<T>>
Modifier and Type | Class and Description |
---|---|
static class |
MaxWithRetractAggFunction.BooleanMaxWithRetractAggFunction
Built-in Boolean Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.ByteMaxWithRetractAggFunction
Built-in Byte Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.DateMaxWithRetractAggFunction
Built-in Date Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.DecimalMaxWithRetractAggFunction
Built-in Big Decimal Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.DoubleMaxWithRetractAggFunction
Built-in Double Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.FloatMaxWithRetractAggFunction
Built-in Float Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.IntMaxWithRetractAggFunction
Built-in Int Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.LongMaxWithRetractAggFunction
Built-in Long Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.MaxWithRetractAccumulator<T>
The initial accumulator for Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.ShortMaxWithRetractAggFunction
Built-in Short Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.StringMaxWithRetractAggFunction
Built-in String Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.TimeMaxWithRetractAggFunction
Built-in Time Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.TimestampMaxWithRetractAggFunction
Built-in Timestamp Max with retraction aggregate function.
|
Constructor and Description |
---|
MaxWithRetractAggFunction() |
getKind, getRequirements, requiresOver
close, functionIdentifier, open, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
isDeterministic
public MaxWithRetractAggFunction.MaxWithRetractAccumulator<T> createAccumulator()
UserDefinedAggregateFunction
UserDefinedAggregateFunction
. The
accumulator is used to keep the aggregated values which are needed to compute an aggregation
result.createAccumulator
in class UserDefinedAggregateFunction<T extends Comparable,MaxWithRetractAggFunction.MaxWithRetractAccumulator<T extends Comparable>>
public void accumulate(MaxWithRetractAggFunction.MaxWithRetractAccumulator<T> acc, Object value) throws Exception
Exception
public void retract(MaxWithRetractAggFunction.MaxWithRetractAccumulator<T> acc, Object value) throws Exception
Exception
public void merge(MaxWithRetractAggFunction.MaxWithRetractAccumulator<T> acc, Iterable<MaxWithRetractAggFunction.MaxWithRetractAccumulator<T>> its) throws Exception
Exception
public void resetAccumulator(MaxWithRetractAggFunction.MaxWithRetractAccumulator<T> acc)
public T getValue(MaxWithRetractAggFunction.MaxWithRetractAccumulator<T> acc)
AggregateFunction
getValue
in class AggregateFunction<T extends Comparable,MaxWithRetractAggFunction.MaxWithRetractAccumulator<T extends Comparable>>
acc
- the accumulator which contains the current
aggregated resultspublic TypeInformation<MaxWithRetractAggFunction.MaxWithRetractAccumulator<T>> getAccumulatorType()
UserDefinedAggregateFunction
TypeInformation
of the UserDefinedAggregateFunction
's accumulator.getAccumulatorType
in class UserDefinedAggregateFunction<T extends Comparable,MaxWithRetractAggFunction.MaxWithRetractAccumulator<T extends Comparable>>
TypeInformation
of the UserDefinedAggregateFunction
's accumulator
or null
if the accumulator type should be automatically inferred.public TypeInformation<T> getResultType()
UserDefinedAggregateFunction
TypeInformation
of the UserDefinedAggregateFunction
's result.getResultType
in class UserDefinedAggregateFunction<T extends Comparable,MaxWithRetractAggFunction.MaxWithRetractAccumulator<T extends Comparable>>
TypeInformation
of the UserDefinedAggregateFunction
's result or
null
if the result type should be automatically inferred.protected abstract TypeInformation<T> getValueTypeInfo()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.