public abstract class MinWithRetractAggFunction<T extends Comparable> extends AggregateFunction<T,MinWithRetractAggFunction.MinWithRetractAccumulator<T>>
Modifier and Type | Class and Description |
---|---|
static class |
MinWithRetractAggFunction.BooleanMinWithRetractAggFunction
Built-in Boolean Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.ByteMinWithRetractAggFunction
Built-in Byte Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.DateMinWithRetractAggFunction
Built-in Date Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.DecimalMinWithRetractAggFunction
Built-in Big DecimalData Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.DoubleMinWithRetractAggFunction
Built-in Double Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.FloatMinWithRetractAggFunction
Built-in Float Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.IntMinWithRetractAggFunction
Built-in Int Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.LongMinWithRetractAggFunction
Built-in Long Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.MinWithRetractAccumulator<T>
The initial accumulator for Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.ShortMinWithRetractAggFunction
Built-in Short Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.StringMinWithRetractAggFunction
Built-in String Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.TimeMinWithRetractAggFunction
Built-in Time Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.TimestampMinWithRetractAggFunction
Built-in Timestamp Min with retraction aggregate function.
|
Constructor and Description |
---|
MinWithRetractAggFunction() |
getKind, getRequirements, getTypeInference, requiresOver
close, functionIdentifier, open, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
isDeterministic
public MinWithRetractAggFunction.MinWithRetractAccumulator<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,MinWithRetractAggFunction.MinWithRetractAccumulator<T extends Comparable>>
public void accumulate(MinWithRetractAggFunction.MinWithRetractAccumulator<T> acc, Object value) throws Exception
Exception
public void retract(MinWithRetractAggFunction.MinWithRetractAccumulator<T> acc, Object value) throws Exception
Exception
public void merge(MinWithRetractAggFunction.MinWithRetractAccumulator<T> acc, Iterable<MinWithRetractAggFunction.MinWithRetractAccumulator<T>> its) throws Exception
Exception
public void resetAccumulator(MinWithRetractAggFunction.MinWithRetractAccumulator<T> acc)
public T getValue(MinWithRetractAggFunction.MinWithRetractAccumulator<T> acc)
AggregateFunction
getValue
in class AggregateFunction<T extends Comparable,MinWithRetractAggFunction.MinWithRetractAccumulator<T extends Comparable>>
acc
- the accumulator which contains the current aggregated resultspublic TypeInformation<MinWithRetractAggFunction.MinWithRetractAccumulator<T>> getAccumulatorType()
UserDefinedAggregateFunction
TypeInformation
of the UserDefinedAggregateFunction
's
accumulator.getAccumulatorType
in class UserDefinedAggregateFunction<T extends Comparable,MinWithRetractAggFunction.MinWithRetractAccumulator<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,MinWithRetractAggFunction.MinWithRetractAccumulator<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–2021 The Apache Software Foundation. All rights reserved.