|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.esper.eql.expression.AggregationServiceNull
public class AggregationServiceNull
A null object implementation of the AggregationService interface.
Constructor Summary | |
---|---|
AggregationServiceNull()
|
Method Summary | |
---|---|
void |
applyEnter(EventBean[] eventsPerStream,
MultiKey optionalGroupKeyPerRow)
Apply events as entering a window (new events). |
void |
applyLeave(EventBean[] eventsPerStream,
MultiKey optionalGroupKeyPerRow)
Apply events as leaving a window (old events). |
Object |
getValue(int column)
Returns current aggregation state, for use by expression node representing an aggregation function. |
void |
setCurrentRow(MultiKey groupKey)
Set the current aggregation state row - for use when evaluation nodes are asked to evaluate. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public AggregationServiceNull()
Method Detail |
---|
public void applyEnter(EventBean[] eventsPerStream, MultiKey optionalGroupKeyPerRow)
AggregationService
applyEnter
in interface AggregationService
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.public void applyLeave(EventBean[] eventsPerStream, MultiKey optionalGroupKeyPerRow)
AggregationService
applyLeave
in interface AggregationService
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.public void setCurrentRow(MultiKey groupKey)
AggregationService
setCurrentRow
in interface AggregationService
groupKey
- - key identify the row of aggregation statespublic Object getValue(int column)
AggregationResultFuture
getValue
in interface AggregationResultFuture
column
- is assigned to the aggregation expression node and passed as an column (index) into a row
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |