com.espertech.esper.epl.agg.access

Class AggregationAgentDefault

java.lang.Object

com.espertech.esper.epl.agg.access.AggregationAgentDefault

All Implemented Interfaces:

AggregationAgent, AggregationAgentForge

public class AggregationAgentDefault
extends java.lang.Object
implements AggregationAgent, AggregationAgentForge

Field Summary

Fields

Modifier and Type	Field and Description
static AggregationAgentDefault	INSTANCE

Method Summary

Modifier and Type	Method and Description
void	applyEnter(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationState aggregationState)
CodegenExpression	applyEnterCodegen(CodegenMethodScope parent, AggregationAgentCodegenSymbols symbols, CodegenClassScope classScope)
void	applyLeave(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationState aggregationState)
CodegenExpression	applyLeaveCodegen(CodegenMethodScope parent, AggregationAgentCodegenSymbols symbols, CodegenClassScope classScope)
ExprForge	getOptionalFilter()
AggregationAgent	makeAgent(EngineImportService engineImportService, boolean isFireAndForget, java.lang.String statementName)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.espertech.esper.epl.agg.access.AggregationAgentForge

getPluginCodegenType

Field Detail

INSTANCE

public static final AggregationAgentDefault INSTANCE

Method Detail

makeAgent

public AggregationAgent makeAgent(EngineImportService engineImportService,
                                  boolean isFireAndForget,
                                  java.lang.String statementName)

Specified by:

makeAgent in interface AggregationAgentForge

applyEnter

public void applyEnter(EventBean[] eventsPerStream,
                       ExprEvaluatorContext exprEvaluatorContext,
                       AggregationState aggregationState)

Specified by:

applyEnter in interface AggregationAgent

applyLeave

public void applyLeave(EventBean[] eventsPerStream,
                       ExprEvaluatorContext exprEvaluatorContext,
                       AggregationState aggregationState)

Specified by:

applyLeave in interface AggregationAgent

applyEnterCodegen

public CodegenExpression applyEnterCodegen(CodegenMethodScope parent,
                                           AggregationAgentCodegenSymbols symbols,
                                           CodegenClassScope classScope)

Specified by:

applyEnterCodegen in interface AggregationAgentForge

applyLeaveCodegen

public CodegenExpression applyLeaveCodegen(CodegenMethodScope parent,
                                           AggregationAgentCodegenSymbols symbols,
                                           CodegenClassScope classScope)

Specified by:

applyLeaveCodegen in interface AggregationAgentForge

getOptionalFilter

public ExprForge getOptionalFilter()

Specified by:

getOptionalFilter in interface AggregationAgentForge