public final class ListAggWsWithRetractAggFunction extends AggregateFunction<BinaryString,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() |
Modifier and Type | Method and Description |
---|---|
void |
accumulate(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator acc,
BinaryString value,
BinaryString lineDelimiter) |
ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator |
createAccumulator()
Creates and initializes the accumulator for this
UserDefinedAggregateFunction . |
BinaryString |
getValue(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator acc)
Called every time when an aggregation result should be materialized.
|
void |
merge(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator acc,
Iterable<ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator> its) |
void |
resetAccumulator(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator acc) |
void |
retract(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator acc,
BinaryString value,
BinaryString lineDelimiter) |
getKind, getRequirements, requiresOver
getAccumulatorType, getResultType
close, functionIdentifier, open, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
isDeterministic
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<BinaryString,ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator>
public void accumulate(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator acc, BinaryString value, BinaryString lineDelimiter) throws Exception
Exception
public void retract(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator acc, BinaryString value, BinaryString lineDelimiter) throws Exception
Exception
public void merge(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator acc, Iterable<ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator> its) throws Exception
Exception
public BinaryString getValue(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator acc)
AggregateFunction
getValue
in class AggregateFunction<BinaryString,ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator>
acc
- the accumulator which contains the current
aggregated resultspublic void resetAccumulator(ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator acc)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.