Package | Description |
---|---|
org.apache.flink.table.runtime.functions.aggregate |
Modifier and Type | Method and Description |
---|---|
CollectAggFunction.CollectAccumulator<T> |
CollectAggFunction.createAccumulator() |
Modifier and Type | Method and Description |
---|---|
void |
CollectAggFunction.accumulate(CollectAggFunction.CollectAccumulator<T> accumulator,
T value) |
MapData |
CollectAggFunction.getValue(CollectAggFunction.CollectAccumulator<T> accumulator) |
void |
CollectAggFunction.merge(CollectAggFunction.CollectAccumulator<T> accumulator,
Iterable<CollectAggFunction.CollectAccumulator<T>> others) |
void |
CollectAggFunction.resetAccumulator(CollectAggFunction.CollectAccumulator<T> accumulator) |
void |
CollectAggFunction.retract(CollectAggFunction.CollectAccumulator<T> accumulator,
T value) |
Modifier and Type | Method and Description |
---|---|
void |
CollectAggFunction.merge(CollectAggFunction.CollectAccumulator<T> accumulator,
Iterable<CollectAggFunction.CollectAccumulator<T>> others) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.