|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.espertech.esper.epl.agg.service.AggSvcGroupAllAccessOnlyImpl
public class AggSvcGroupAllAccessOnlyImpl
Aggregation service for use when only first/last/window aggregation functions are used an none other.
Field Summary | |
---|---|
protected AggregationState[] |
states
|
Constructor Summary | |
---|---|
AggSvcGroupAllAccessOnlyImpl(AggregationAccessorSlotPair[] accessors,
AggregationState[] states)
|
Method Summary | |
---|---|
void |
applyEnter(EventBean[] eventsPerStream,
java.lang.Object groupKey,
ExprEvaluatorContext exprEvaluatorContext)
Apply events as entering a window (new events). |
void |
applyLeave(EventBean[] eventsPerStream,
java.lang.Object groupKey,
ExprEvaluatorContext exprEvaluatorContext)
Apply events as leaving a window (old events). |
void |
clearResults(ExprEvaluatorContext exprEvaluatorContext)
Clear current aggregation state. |
java.util.Collection<EventBean> |
getCollection(int column,
ExprEvaluatorContext context)
|
EventBean |
getEventBean(int column,
ExprEvaluatorContext context)
|
java.lang.Object |
getValue(int column,
int agentInstanceId)
Returns current aggregation state, for use by expression node representing an aggregation function. |
void |
setCurrentAccess(java.lang.Object groupKey,
int agentInstanceId)
Set the current aggregation state row - for use when evaluation nodes are asked to evaluate. |
void |
setRemovedCallback(AggregationRowRemovedCallback callback)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected final AggregationState[] states
Constructor Detail |
---|
public AggSvcGroupAllAccessOnlyImpl(AggregationAccessorSlotPair[] accessors, AggregationState[] states)
Method Detail |
---|
public void applyEnter(EventBean[] eventsPerStream, java.lang.Object groupKey, ExprEvaluatorContext exprEvaluatorContext)
AggregationService
applyEnter
in interface AggregationService
eventsPerStream
- - events for each stream entering windowgroupKey
- - 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.exprEvaluatorContext
- context for expression evaluatiompublic void applyLeave(EventBean[] eventsPerStream, java.lang.Object groupKey, ExprEvaluatorContext exprEvaluatorContext)
AggregationService
applyLeave
in interface AggregationService
eventsPerStream
- - events for each stream entering windowgroupKey
- - 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.exprEvaluatorContext
- context for expression evaluatiompublic void setCurrentAccess(java.lang.Object groupKey, int agentInstanceId)
AggregationService
setCurrentAccess
in interface AggregationService
groupKey
- - key identify the row of aggregation statesagentInstanceId
- context partition idpublic java.lang.Object getValue(int column, int agentInstanceId)
AggregationResultFuture
getValue
in interface AggregationResultFuture
column
- is assigned to the aggregation expression node and passed as an column (index) into a rowagentInstanceId
- the context partition id
public EventBean getEventBean(int column, ExprEvaluatorContext context)
getEventBean
in interface AggregationResultFuture
public java.util.Collection<EventBean> getCollection(int column, ExprEvaluatorContext context)
getCollection
in interface AggregationResultFuture
public void clearResults(ExprEvaluatorContext exprEvaluatorContext)
AggregationService
clearResults
in interface AggregationService
public void setRemovedCallback(AggregationRowRemovedCallback callback)
setRemovedCallback
in interface AggregationService
|
© 2006-2011 EsperTech Inc. All rights reserved. Visit us at espertech.com |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |