public final class ListAggWsWithRetractAggFunction extends AggregateFunction<StringData,ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator>
Modifier and Type | Class and Description |
---|---|
static class |
ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator
The initial accumulator for concat with retraction aggregate function.
|
Constructor and Description |
---|
ListAggWsWithRetractAggFunction() |
getKind, getRequirements, getTypeInference, requiresOver
close, functionIdentifier, open, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
isDeterministic
public TypeInformation<StringData> getResultType()
UserDefinedAggregateFunction
TypeInformation
of the UserDefinedAggregateFunction
's result.getResultType
in class UserDefinedAggregateFunction<StringData,ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator>
TypeInformation
of the UserDefinedAggregateFunction
's result or
null
if the result type should be automatically inferred.public TypeInformation<ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator> getAccumulatorType()
UserDefinedAggregateFunction
TypeInformation
of the UserDefinedAggregateFunction
's
accumulator.getAccumulatorType
in class UserDefinedAggregateFunction<StringData,ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator>
TypeInformation
of the UserDefinedAggregateFunction
's accumulator
or null
if the accumulator type should be automatically inferred.public ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator createAccumulator()
UserDefinedAggregateFunction
UserDefinedAggregateFunction
. The
accumulator is used to keep the aggregated values which are needed to compute an aggregation
result.createAccumulator
in class UserDefinedAggregateFunction<StringData,ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator>
public void accumulate(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator acc, StringData value, StringData lineDelimiter) throws Exception
Exception
public void retract(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator acc, StringData value, StringData lineDelimiter) throws Exception
Exception
public void merge(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator acc, Iterable<ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator> its) throws Exception
Exception
public StringData getValue(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator acc)
AggregateFunction
getValue
in class AggregateFunction<StringData,ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator>
acc
- the accumulator which contains the current aggregated resultspublic void resetAccumulator(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator acc)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.