com.espertech.esper.epl.agg.service

Class AggregationServiceMatchRecognizeImpl

java.lang.Object

com.espertech.esper.epl.agg.service.AggregationServiceMatchRecognizeImpl

All Implemented Interfaces:

AggregationResultFuture, AggregationServiceMatchRecognize

public class AggregationServiceMatchRecognizeImpl
extends Object
implements AggregationServiceMatchRecognize

Implements an aggregation service for match recognize.

Constructor Summary

Constructors

Constructor and Description
AggregationServiceMatchRecognizeImpl(ExprEvaluator[][] evaluatorsEachStream, AggregationMethod[][] aggregatorsEachStream, AggregationMethod[] aggregatorsAll)

Method Summary

Modifier and Type	Method and Description
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.
Collection<EventBean>	getCollectionOfEvents(int column, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
Collection<Object>	getCollectionScalar(int column, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
EventBean	getEventBean(int column, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
Object	getGroupKey(int agentInstanceId)
Collection<Object>	getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
Object	getValue(int column, int agentInstanceId, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) 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

AggregationServiceMatchRecognizeImpl

public AggregationServiceMatchRecognizeImpl(ExprEvaluator[][] evaluatorsEachStream,
                                            AggregationMethod[][] aggregatorsEachStream,
                                            AggregationMethod[] aggregatorsAll)

Method Detail

applyEnter

public void applyEnter(EventBean[] eventsPerStream,
                       int streamId,
                       ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: AggregationServiceMatchRecognize

Enter a single event row consisting of one or more events per stream (each stream representing a variable).

Specified by:

applyEnter in interface AggregationServiceMatchRecognize

Parameters:

eventsPerStream - events per stream

streamId - variable number that is the base

exprEvaluatorContext - context for expression evaluatiom

getValue

public Object getValue(int column,
                       int agentInstanceId,
                       EventBean[] eventsPerStream,
                       boolean isNewData,
                       ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: AggregationResultFuture

Returns current aggregation state, for use by expression node representing an aggregation function.

Specified by:

getValue in interface AggregationResultFuture

Parameters:

column - is assigned to the aggregation expression node and passed as an column (index) into a row

agentInstanceId - the context partition id

eventsPerStream - events per stream

isNewData - new vs removed indicator

exprEvaluatorContext - context

Returns:

current aggragation state

getCollectionOfEvents

public Collection<EventBean> getCollectionOfEvents(int column,
                                                   EventBean[] eventsPerStream,
                                                   boolean isNewData,
                                                   ExprEvaluatorContext context)

Specified by:

getCollectionOfEvents in interface AggregationResultFuture

getCollectionScalar

public Collection<Object> getCollectionScalar(int column,
                                              EventBean[] eventsPerStream,
                                              boolean isNewData,
                                              ExprEvaluatorContext context)

Specified by:

getCollectionScalar in interface AggregationResultFuture

getEventBean

public EventBean getEventBean(int column,
                              EventBean[] eventsPerStream,
                              boolean isNewData,
                              ExprEvaluatorContext context)

Specified by:

getEventBean in interface AggregationResultFuture

clearResults

public void clearResults()

Description copied from interface: AggregationServiceMatchRecognize

Clear current aggregation state.

Specified by:

clearResults in interface AggregationServiceMatchRecognize

getGroupKey

public Object getGroupKey(int agentInstanceId)

Specified by:

getGroupKey in interface AggregationResultFuture

getGroupKeys

public Collection<Object> getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)

Specified by:

getGroupKeys in interface AggregationResultFuture