stream.scotty.core.windowFunction

Interface InvertibleAggregateFunction<InputType,PartialAggregateType,FinalAggregateType>

All Superinterfaces:

AggregateFunction<InputType,PartialAggregateType,FinalAggregateType>, java.io.Serializable

All Known Subinterfaces:

InvertibleReduceAggregateFunction<Input>

All Known Implementing Classes:

SumAggregation, SumWindowFunction

public interface InvertibleAggregateFunction<InputType,PartialAggregateType,FinalAggregateType>
extends AggregateFunction<InputType,PartialAggregateType,FinalAggregateType>

Method Summary

Modifier and Type	Method and Description
PartialAggregateType	invert(PartialAggregateType currentAggregate, PartialAggregateType toRemove) Removes one partial aggregate from another with an incremental operation.

Methods inherited from interface stream.scotty.core.windowFunction.AggregateFunction

combine, lift, lower

Method Detail

invert

PartialAggregateType invert(PartialAggregateType currentAggregate,
                            PartialAggregateType toRemove)

Removes one partial aggregate from another with an incremental operation.

Parameters:

currentAggregate -

toRemove -

Returns: