|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface AggregationService
Service for maintaing aggregation state. Processes events entering (a window, a join etc,) and events leaving. Answers questions about current aggrataion state for a given row.
Method Summary | |
---|---|
void |
applyEnter(EventBean[] eventsPerStream,
MultiKeyUntyped optionalGroupKeyPerRow)
Apply events as entering a window (new events). |
void |
applyLeave(EventBean[] eventsPerStream,
MultiKeyUntyped optionalGroupKeyPerRow)
Apply events as leaving a window (old events). |
void |
setCurrentRow(MultiKeyUntyped groupKey)
Set the current aggregation state row - for use when evaluation nodes are asked to evaluate. |
Methods inherited from interface net.esper.eql.agg.AggregationResultFuture |
---|
getValue |
Method Detail |
---|
void applyEnter(EventBean[] eventsPerStream, MultiKeyUntyped optionalGroupKeyPerRow)
eventsPerStream
- - events for each stream entering windowoptionalGroupKeyPerRow
- - can be null if grouping without keys is desired, else the keys
to use for grouping, each distinct key value results in a new row of aggregation state.void applyLeave(EventBean[] eventsPerStream, MultiKeyUntyped optionalGroupKeyPerRow)
eventsPerStream
- - events for each stream entering windowoptionalGroupKeyPerRow
- - can be null if grouping without keys is desired, else the keys
to use for grouping, each distinct key value results in a new row of aggregation state.void setCurrentRow(MultiKeyUntyped groupKey)
groupKey
- - key identify the row of aggregation states
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |