|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.espertech.esper.epl.agg.service.AggregationServiceMatchRecognizeImpl
public class AggregationServiceMatchRecognizeImpl
Implements an aggregation service for match recognize.
Constructor Summary | |
---|---|
AggregationServiceMatchRecognizeImpl(ExprEvaluator[][] evaluatorsEachStream,
AggregationMethod[][] aggregatorsEachStream,
AggregationMethod[] aggregatorsAll)
|
Method Summary | |
---|---|
void |
applyEnter(EventBean[] eventsPerStream,
int streamId,
ExprEvaluatorContext exprEvaluatorContext)
Enter a single event row consisting of one or more events per stream (each stream representing a variable). |
void |
clearResults()
Clear current aggregation state. |
java.util.Collection<EventBean> |
getCollection(int column,
ExprEvaluatorContext context)
|
EventBean |
getEventBean(int column,
ExprEvaluatorContext context)
|
java.lang.Object |
getGroupKey(int agentInstanceId)
|
java.util.Collection<java.lang.Object> |
getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
getValue(int column,
int agentInstanceId)
Returns current aggregation state, for use by expression node representing an aggregation function. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public AggregationServiceMatchRecognizeImpl(ExprEvaluator[][] evaluatorsEachStream, AggregationMethod[][] aggregatorsEachStream, AggregationMethod[] aggregatorsAll)
Method Detail |
---|
public void applyEnter(EventBean[] eventsPerStream, int streamId, ExprEvaluatorContext exprEvaluatorContext)
AggregationServiceMatchRecognize
applyEnter
in interface AggregationServiceMatchRecognize
eventsPerStream
- events per streamstreamId
- variable number that is the baseexprEvaluatorContext
- context for expression evaluatiompublic 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 clearResults()
AggregationServiceMatchRecognize
clearResults
in interface AggregationServiceMatchRecognize
public java.lang.Object getGroupKey(int agentInstanceId)
getGroupKey
in interface AggregationResultFuture
public java.util.Collection<java.lang.Object> getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
getGroupKeys
in interface AggregationResultFuture
|
© 2006-2014 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 |