Class ArrayAggFunction.ArrayAggAccumulator<T>
- java.lang.Object
-
- org.apache.flink.table.runtime.functions.aggregate.ArrayAggFunction.ArrayAggAccumulator<T>
-
- Enclosing class:
- ArrayAggFunction<T>
public static class ArrayAggFunction.ArrayAggAccumulator<T> extends Object
Accumulator for ARRAY_AGG with retraction.
-
-
Field Summary
Fields Modifier and Type Field Description LinkedList<T>listLinkedList<T>retractList
-
Constructor Summary
Constructors Constructor Description ArrayAggAccumulator()
-
-
-
Field Detail
-
list
public LinkedList<T> list
-
retractList
public LinkedList<T> retractList
-
-