@FunctionalInterface public interface ReduceAggregateFunction<InputType> extends AggregateFunction<InputType,InputType,InputType>
| Modifier and Type | Method and Description |
|---|---|
default InputType |
lift(InputType inputTuple)
Transforms a tuple to a partial aggregate.
|
default InputType |
lower(InputType aggregate)
Transforms a partial aggregate to a final aggregate.
|
combinedefault InputType lift(InputType inputTuple)
AggregateFunctionlift in interface AggregateFunction<InputType,InputType,InputType>inputTuple - input Tupledefault InputType lower(InputType aggregate)
AggregateFunctionlower in interface AggregateFunction<InputType,InputType,InputType>