Package org.apache.s4.core.window

Provides facilities for processing events as samples, through time or count-based windows.

See:
          Description

Interface Summary
Slot<T> A convenience window slot, that aggregates elements of type .
SlotFactory<T> Defines factory for window slots
 

Class Summary
AbstractSlidingWindowPE<T extends Slot<U>,U,V> Abstract ProcessingElement that can store historical values using a sliding window.
DefaultAggregatingSlot<T> Window slot that keeps all data elements as a list.
DefaultAggregatingSlot.DefaultAggregatingSlotFactory<T>  
OHCLSlot  
OHCLSlot.OHCLSlotFactory  
 

Package org.apache.s4.core.window Description

Provides facilities for processing events as samples, through time or count-based windows. Currently we only provide a facility for sliding windows. NOTE: we are still working on improving the API here.