|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.esper.eql.core.AggregationServiceBase
net.esper.eql.core.AggregationServiceGroupByImpl
public class AggregationServiceGroupByImpl
Implementation for handling aggregation with grouping by group-keys.
Field Summary |
---|
Fields inherited from class net.esper.eql.core.AggregationServiceBase |
---|
aggregators, evaluators |
Constructor Summary | |
---|---|
AggregationServiceGroupByImpl(ExprEvaluator[] evaluators,
Aggregator[] aggregators)
Ctor. |
Method Summary | |
---|---|
void |
applyEnter(EventBean[] eventsPerStream,
MultiKeyUntyped groupByKey)
Apply events as entering a window (new events). |
void |
applyLeave(EventBean[] eventsPerStream,
MultiKeyUntyped groupByKey)
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(MultiKeyUntyped groupByKey)
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 AggregationServiceGroupByImpl(ExprEvaluator[] evaluators, Aggregator[] aggregators)
evaluators
- - evaluate the sub-expression within the aggregate function (ie. sum(4*myNum))aggregators
- - collect the aggregation state that evaluators evaluate to, act as factories for new
aggregation states for each groupMethod Detail |
---|
public void applyEnter(EventBean[] eventsPerStream, MultiKeyUntyped groupByKey)
AggregationService
eventsPerStream
- - events for each stream entering windowgroupByKey
- - 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, MultiKeyUntyped groupByKey)
AggregationService
eventsPerStream
- - events for each stream entering windowgroupByKey
- - 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(MultiKeyUntyped groupByKey)
AggregationService
groupByKey
- - key identify the row of aggregation statespublic Object getValue(int column)
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 |