|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.espertech.esper.core.context.stmt.AIRegistryAggregationSingle
public class AIRegistryAggregationSingle
Constructor Summary | |
---|---|
AIRegistryAggregationSingle()
|
Method Summary | |
---|---|
void |
applyEnter(EventBean[] eventsPerStream,
java.lang.Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
Apply events as entering a window (new events). |
void |
applyLeave(EventBean[] eventsPerStream,
java.lang.Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
Apply events as leaving a window (old events). |
void |
assignService(int serviceId,
AggregationService aggregationService)
|
void |
clearResults(ExprEvaluatorContext exprEvaluatorContext)
Clear current aggregation state. |
void |
deassignService(int serviceId)
|
java.util.Collection<EventBean> |
getCollection(int column,
ExprEvaluatorContext context)
|
EventBean |
getEventBean(int column,
ExprEvaluatorContext context)
|
int |
getInstanceCount()
|
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 |
Constructor Detail |
---|
public AIRegistryAggregationSingle()
Method Detail |
---|
public void assignService(int serviceId, AggregationService aggregationService)
assignService
in interface AIRegistryAggregation
public void deassignService(int serviceId)
deassignService
in interface AIRegistryAggregation
public int getInstanceCount()
getInstanceCount
in interface AIRegistryAggregation
public void applyEnter(EventBean[] eventsPerStream, java.lang.Object optionalGroupKeyPerRow, ExprEvaluatorContext exprEvaluatorContext)
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.exprEvaluatorContext
- context for expression evaluatiompublic void applyLeave(EventBean[] eventsPerStream, java.lang.Object optionalGroupKeyPerRow, ExprEvaluatorContext exprEvaluatorContext)
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.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 void clearResults(ExprEvaluatorContext exprEvaluatorContext)
AggregationService
clearResults
in interface AggregationService
public 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 java.util.Collection<EventBean> getCollection(int column, ExprEvaluatorContext context)
getCollection
in interface AggregationResultFuture
public EventBean getEventBean(int column, ExprEvaluatorContext context)
getEventBean
in interface AggregationResultFuture
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 |