Package com.espertech.esper.common.internal.epl.agg.groupby

Class AggregationServiceGroupByForge

java.lang.Object

com.espertech.esper.common.internal.epl.agg.groupby.AggregationServiceGroupByForge

All Implemented Interfaces:

AggregationServiceFactoryForge, AggregationServiceFactoryForgeWMethodGen

public class AggregationServiceGroupByForge
extends Object
implements AggregationServiceFactoryForgeWMethodGen

Implementation for handling aggregation with grouping by group-keys.

Field Summary

Fields

Modifier and Type	Field	Description
protected final AggGroupByDesc	aggGroupByDesc
protected CodegenExpression	reclaimAge
protected CodegenExpression	reclaimFreq
protected final TimeAbacus	timeAbacus

Constructor Summary

Constructors

Constructor	Description
AggregationServiceGroupByForge(AggGroupByDesc aggGroupByDesc, TimeAbacus timeAbacus)

Method Summary

Modifier and Type	Method	Description
<T> T	accept(AggregationServiceFactoryForgeVisitor<T> visitor)
void	acceptCodegen(CodegenMethod method, CodegenClassScope classScope)
void	acceptGroupDetailCodegen(CodegenMethod method, CodegenClassScope classScope)
void	appendRowFabricType(FabricTypeCollector fabricTypeCollector)
AppliesTo	appliesTo()
void	applyEnterCodegen(CodegenMethod method, CodegenClassScope classScope, CodegenNamedMethods namedMethods, AggregationClassNames classNames)
void	applyLeaveCodegen(CodegenMethod method, CodegenClassScope classScope, CodegenNamedMethods namedMethods, AggregationClassNames classNames)
void	clearResultsCodegen(CodegenMethod method, CodegenClassScope classScope)
void	ctorCodegen(CodegenCtor ctor, List<CodegenTypedParam> explicitMembers, CodegenClassScope classScope, AggregationClassNames classNames)
AggGroupByDesc	getAggGroupByDesc()
void	getCollectionOfEventsCodegen(CodegenMethod method, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
void	getCollectionScalarCodegen(CodegenMethod method, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
void	getEventBeanCodegen(CodegenMethod method, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
void	getGroupKeyCodegen(CodegenMethod method, CodegenClassScope classScope)
void	getGroupKeysCodegen(CodegenMethod method, CodegenClassScope classScope)
void	getRowCodegen(CodegenMethod method, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
AggregationCodegenRowLevelDesc	getRowLevelDesc()
void	getValueCodegen(CodegenMethod method, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
void	isGroupedCodegen(CodegenMethod method, CodegenClassScope classScope)
void	makeServiceCodegen(CodegenMethod method, CodegenClassScope classScope, AggregationClassNames classNames)
void	providerCodegen(CodegenMethod method, CodegenClassScope classScope, AggregationClassNames classNames)
void	rowCtorCodegen(AggregationRowCtorDesc rowCtorDesc)
void	rowReadMethodCodegen(CodegenMethod method, int level)
void	rowWriteMethodCodegen(CodegenMethod method, int level)
void	setCurrentAccessCodegen(CodegenMethod method, CodegenClassScope classScope, AggregationClassNames classNames)
void	setRemovedCallbackCodegen(CodegenMethod method)
void	setStateMgmtSetting(StateMgmtSetting stateMgmtSetting)
void	stopMethodCodegen(AggregationServiceFactoryForgeWMethodGen forge, CodegenMethod method)

Methods inherited from class java.lang.Object

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

Field Details

aggGroupByDesc

protected final AggGroupByDesc aggGroupByDesc

timeAbacus

protected final TimeAbacus timeAbacus

reclaimAge

protected CodegenExpression reclaimAge

reclaimFreq

protected CodegenExpression reclaimFreq

Constructor Details

AggregationServiceGroupByForge

public AggregationServiceGroupByForge(AggGroupByDesc aggGroupByDesc,
 TimeAbacus timeAbacus)

Method Details

appliesTo

public AppliesTo appliesTo()

Specified by:

appliesTo in interface AggregationServiceFactoryForge

setStateMgmtSetting

public void setStateMgmtSetting(StateMgmtSetting stateMgmtSetting)

Specified by:

setStateMgmtSetting in interface AggregationServiceFactoryForge

appendRowFabricType

public void appendRowFabricType(FabricTypeCollector fabricTypeCollector)

Specified by:

appendRowFabricType in interface AggregationServiceFactoryForge

providerCodegen

public void providerCodegen(CodegenMethod method,
 CodegenClassScope classScope,
 AggregationClassNames classNames)

Specified by:

providerCodegen in interface AggregationServiceFactoryForgeWMethodGen

rowCtorCodegen

public void rowCtorCodegen(AggregationRowCtorDesc rowCtorDesc)

Specified by:

rowCtorCodegen in interface AggregationServiceFactoryForgeWMethodGen

rowWriteMethodCodegen

public void rowWriteMethodCodegen(CodegenMethod method,
 int level)

Specified by:

rowWriteMethodCodegen in interface AggregationServiceFactoryForgeWMethodGen

rowReadMethodCodegen

public void rowReadMethodCodegen(CodegenMethod method,
 int level)

Specified by:

rowReadMethodCodegen in interface AggregationServiceFactoryForgeWMethodGen

makeServiceCodegen

public void makeServiceCodegen(CodegenMethod method,
 CodegenClassScope classScope,
 AggregationClassNames classNames)

Specified by:

makeServiceCodegen in interface AggregationServiceFactoryForgeWMethodGen

ctorCodegen

public void ctorCodegen(CodegenCtor ctor,
 List<CodegenTypedParam> explicitMembers,
 CodegenClassScope classScope,
 AggregationClassNames classNames)

Specified by:

ctorCodegen in interface AggregationServiceFactoryForgeWMethodGen

getValueCodegen

public void getValueCodegen(CodegenMethod method,
 CodegenClassScope classScope,
 CodegenNamedMethods namedMethods)

Specified by:

getValueCodegen in interface AggregationServiceFactoryForgeWMethodGen

getEventBeanCodegen

public void getEventBeanCodegen(CodegenMethod method,
 CodegenClassScope classScope,
 CodegenNamedMethods namedMethods)

Specified by:

getEventBeanCodegen in interface AggregationServiceFactoryForgeWMethodGen

getCollectionScalarCodegen

public void getCollectionScalarCodegen(CodegenMethod method,
 CodegenClassScope classScope,
 CodegenNamedMethods namedMethods)

Specified by:

getCollectionScalarCodegen in interface AggregationServiceFactoryForgeWMethodGen

getCollectionOfEventsCodegen

public void getCollectionOfEventsCodegen(CodegenMethod method,
 CodegenClassScope classScope,
 CodegenNamedMethods namedMethods)

Specified by:

getCollectionOfEventsCodegen in interface AggregationServiceFactoryForgeWMethodGen

applyEnterCodegen

public void applyEnterCodegen(CodegenMethod method,
 CodegenClassScope classScope,
 CodegenNamedMethods namedMethods,
 AggregationClassNames classNames)

Specified by:

applyEnterCodegen in interface AggregationServiceFactoryForgeWMethodGen

applyLeaveCodegen

public void applyLeaveCodegen(CodegenMethod method,
 CodegenClassScope classScope,
 CodegenNamedMethods namedMethods,
 AggregationClassNames classNames)

Specified by:

applyLeaveCodegen in interface AggregationServiceFactoryForgeWMethodGen

stopMethodCodegen

public void stopMethodCodegen(AggregationServiceFactoryForgeWMethodGen forge,
 CodegenMethod method)

Specified by:

stopMethodCodegen in interface AggregationServiceFactoryForgeWMethodGen

setRemovedCallbackCodegen

public void setRemovedCallbackCodegen(CodegenMethod method)

Specified by:

setRemovedCallbackCodegen in interface AggregationServiceFactoryForgeWMethodGen

setCurrentAccessCodegen

public void setCurrentAccessCodegen(CodegenMethod method,
 CodegenClassScope classScope,
 AggregationClassNames classNames)

Specified by:

setCurrentAccessCodegen in interface AggregationServiceFactoryForgeWMethodGen

clearResultsCodegen

public void clearResultsCodegen(CodegenMethod method,
 CodegenClassScope classScope)

Specified by:

clearResultsCodegen in interface AggregationServiceFactoryForgeWMethodGen

getRowLevelDesc

public AggregationCodegenRowLevelDesc getRowLevelDesc()

Specified by:

getRowLevelDesc in interface AggregationServiceFactoryForgeWMethodGen

acceptCodegen

public void acceptCodegen(CodegenMethod method,
 CodegenClassScope classScope)

Specified by:

acceptCodegen in interface AggregationServiceFactoryForgeWMethodGen

getGroupKeysCodegen

public void getGroupKeysCodegen(CodegenMethod method,
 CodegenClassScope classScope)

Specified by:

getGroupKeysCodegen in interface AggregationServiceFactoryForgeWMethodGen

getGroupKeyCodegen

public void getGroupKeyCodegen(CodegenMethod method,
 CodegenClassScope classScope)

Specified by:

getGroupKeyCodegen in interface AggregationServiceFactoryForgeWMethodGen

acceptGroupDetailCodegen

public void acceptGroupDetailCodegen(CodegenMethod method,
 CodegenClassScope classScope)

Specified by:

acceptGroupDetailCodegen in interface AggregationServiceFactoryForgeWMethodGen

isGroupedCodegen

public void isGroupedCodegen(CodegenMethod method,
 CodegenClassScope classScope)

Specified by:

isGroupedCodegen in interface AggregationServiceFactoryForgeWMethodGen

getRowCodegen

public void getRowCodegen(CodegenMethod method,
 CodegenClassScope classScope,
 CodegenNamedMethods namedMethods)

Specified by:

getRowCodegen in interface AggregationServiceFactoryForgeWMethodGen

accept

public <T> T accept(AggregationServiceFactoryForgeVisitor<T> visitor)

Specified by:

accept in interface AggregationServiceFactoryForge

getAggGroupByDesc

public AggGroupByDesc getAggGroupByDesc()