org.apache.s4.core.window
Class DefaultAggregatingSlot<T>

java.lang.Object
  extended by org.apache.s4.core.window.DefaultAggregatingSlot<T>
Type Parameters:
T - Type of slot elements
All Implemented Interfaces:
Slot<T>

public class DefaultAggregatingSlot<T>
extends java.lang.Object
implements Slot<T>

Window slot that keeps all data elements as a list.


Nested Class Summary
static class DefaultAggregatingSlot.DefaultAggregatingSlotFactory<T>
           
 
Constructor Summary
DefaultAggregatingSlot()
           
 
Method Summary
 void close()
          Compute aggregated data on available gathered slot data, place slot and slot data in immutable state.
 java.util.List<T> getAggregatedData()
           
 void update(T datum)
          Add a single data element
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DefaultAggregatingSlot

public DefaultAggregatingSlot()
Method Detail

update

public void update(T datum)
Description copied from interface: Slot
Add a single data element

Specified by:
update in interface Slot<T>

close

public void close()
Description copied from interface: Slot
Compute aggregated data on available gathered slot data, place slot and slot data in immutable state.

Specified by:
close in interface Slot<T>

getAggregatedData

public java.util.List<T> getAggregatedData()