com.espertech.esper.epl.agg.factory

Class AggregationStateFactoryCountMinSketch

java.lang.Object

com.espertech.esper.epl.agg.factory.AggregationStateFactoryCountMinSketch

All Implemented Interfaces:

AggregationStateFactory, AggregationStateFactoryForge

public class AggregationStateFactoryCountMinSketch
extends java.lang.Object
implements AggregationStateFactory, AggregationStateFactoryForge

Field Summary

Fields

Modifier and Type	Field and Description
protected ExprAggCountMinSketchNode	parent
protected CountMinSketchSpec	specification

Constructor Summary

Constructors

Constructor and Description
AggregationStateFactoryCountMinSketch(ExprAggCountMinSketchNode parent, CountMinSketchSpec specification)

Method Summary

Modifier and Type	Method and Description
void	applyEnterCodegen(int stateNumber, CodegenMethodNode method, ExprForgeCodegenSymbol symbols, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
void	applyLeaveCodegen(int stateNumber, CodegenMethodNode method, ExprForgeCodegenSymbol symbols, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
void	clearCodegen(int stateNumber, CodegenMethodNode method, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
AggregationState	createAccess(int agentInstanceId, boolean join, java.lang.Object groupKey, AggregationServicePassThru passThru)
ExprNode	getAggregationExpression()
ExprAggCountMinSketchNode	getParent()
CountMinSketchSpec	getSpecification()
AggregationStateFactory	makeFactory(EngineImportService engineImportService, boolean isFireAndForget, java.lang.String statementName)
void	rowMemberCodegen(int stateNumber, CodegenCtor ctor, CodegenMembersColumnized membersColumnized, CodegenClassScope classScope)

Methods inherited from class java.lang.Object

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

Field Detail

parent

protected final ExprAggCountMinSketchNode parent

specification

protected final CountMinSketchSpec specification

Constructor Detail

AggregationStateFactoryCountMinSketch

public AggregationStateFactoryCountMinSketch(ExprAggCountMinSketchNode parent,
                                             CountMinSketchSpec specification)

Method Detail

makeFactory

public AggregationStateFactory makeFactory(EngineImportService engineImportService,
                                           boolean isFireAndForget,
                                           java.lang.String statementName)

Specified by:

makeFactory in interface AggregationStateFactoryForge

rowMemberCodegen

public void rowMemberCodegen(int stateNumber,
                             CodegenCtor ctor,
                             CodegenMembersColumnized membersColumnized,
                             CodegenClassScope classScope)

Specified by:

rowMemberCodegen in interface AggregationStateFactoryForge

applyEnterCodegen

public void applyEnterCodegen(int stateNumber,
                              CodegenMethodNode method,
                              ExprForgeCodegenSymbol symbols,
                              CodegenClassScope classScope,
                              CodegenNamedMethods namedMethods)

Specified by:

applyEnterCodegen in interface AggregationStateFactoryForge

applyLeaveCodegen

public void applyLeaveCodegen(int stateNumber,
                              CodegenMethodNode method,
                              ExprForgeCodegenSymbol symbols,
                              CodegenClassScope classScope,
                              CodegenNamedMethods namedMethods)

Specified by:

applyLeaveCodegen in interface AggregationStateFactoryForge

clearCodegen

public void clearCodegen(int stateNumber,
                         CodegenMethodNode method,
                         CodegenClassScope classScope,
                         CodegenNamedMethods namedMethods)

Specified by:

clearCodegen in interface AggregationStateFactoryForge

createAccess

public AggregationState createAccess(int agentInstanceId,
                                     boolean join,
                                     java.lang.Object groupKey,
                                     AggregationServicePassThru passThru)

Specified by:

createAccess in interface AggregationStateFactory

getAggregationExpression

public ExprNode getAggregationExpression()

Specified by:

getAggregationExpression in interface AggregationStateFactory

getSpecification

public CountMinSketchSpec getSpecification()

getParent

public ExprAggCountMinSketchNode getParent()