Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

This page is under construction.


Interfaces for a new function

An aggregation function needs to implement one of the following interfaces:

  • de.uniol.inf.is.odysseus.aggregation.functions.

...

  • IIncrementalAggregationFunction
    An incremental aggregation functions gets a notification when an element gets valid (enters the window) or gets invalid (leaves the window). You have to hold a state to return the current aggregation value on request. 
    • void addNew(T newElement);
      This function is called when a new element gets valid. You should add this value to the state.
      For example AVG function: State holds sum and count. sum += newElement and count++ 

...

  • de.uniol.inf.is.odysseus.aggregation.functions.INonIncrementalAggregationFunction