com.espertech.esper.epl.agg.service
Class AggregationServiceMatchRecognizeFactoryImpl

java.lang.Object
  com.espertech.esper.epl.agg.service.AggregationServiceMatchRecognizeFactoryImpl

All Implemented Interfaces:

AggregationServiceMatchRecognizeFactory

public class AggregationServiceMatchRecognizeFactoryImpl
extends java.lang.Object
implements AggregationServiceMatchRecognizeFactory

Implements an aggregation service for match recognize.

Constructor Summary

AggregationServiceMatchRecognizeFactoryImpl(int countStreams, java.util.LinkedHashMap<java.lang.Integer,AggregationMethodFactory[]> aggregatorsPerStream, java.util.Map<java.lang.Integer,ExprEvaluator[]> evaluatorsPerStream)
Ctor.

Method Summary

AggregationServiceMatchRecognize

makeService(AgentInstanceContext agentInstanceContext)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AggregationServiceMatchRecognizeFactoryImpl

public AggregationServiceMatchRecognizeFactoryImpl(int countStreams,
                                                   java.util.LinkedHashMap<java.lang.Integer,AggregationMethodFactory[]> aggregatorsPerStream,
                                                   java.util.Map<java.lang.Integer,ExprEvaluator[]> evaluatorsPerStream)

Ctor.

Parameters:

countStreams - number of streams/variables

aggregatorsPerStream - aggregation methods per stream

evaluatorsPerStream - evaluation functions per stream

Method Detail

makeService

public AggregationServiceMatchRecognize makeService(AgentInstanceContext agentInstanceContext)

Specified by:

makeService in interface AggregationServiceMatchRecognizeFactory