com.espertech.esper.epl.agg.service.table

Class AggSvcGroupByWTableForge

java.lang.Object

com.espertech.esper.epl.agg.service.table.AggSvcGroupByWTableForge

All Implemented Interfaces:

AggregationServiceFactoryForge

public class AggSvcGroupByWTableForge
extends java.lang.Object
implements AggregationServiceFactoryForge

Implementation for handling aggregation with grouping by group-keys.

Constructor Summary

Constructors

Constructor and Description

AggSvcGroupByWTableForge(TableService tableService, TableMetadata tableMetadata, TableColumnMethodPair[] methodPairs, AggregationAccessorSlotPairForge[] accessorForges, AggregationAccessorSlotPair[] accessors, boolean join, int[] targetStates, ExprNode[] accessStateExpr, AggregationAgentForge[] agentForges, AggregationAgent[] agents, AggregationGroupByRollupDesc groupByRollupDesc, boolean hasGroupBy)

Method Summary

Modifier and Type	Method and Description
void	acceptCodegen(CodegenMethodNode method, CodegenClassScope classScope)
void	acceptGroupDetailCodegen(CodegenMethodNode method, CodegenClassScope classScope)
void	applyEnterCodegen(CodegenMethodNode method, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
void	applyLeaveCodegen(CodegenMethodNode method, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
void	clearResultsCodegen(CodegenMethodNode method, CodegenClassScope classScope)
void	ctorCodegen(CodegenCtor ctor, java.util.List<CodegenTypedParam> explicitMembers, CodegenClassScope classScope)
AggregationServiceFactory	getAggregationServiceFactory(StatementContext stmtContext, boolean isFireAndForget)
void	getCodegen(AggSvcTableGetterType getterType, CodegenMethodNode method, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
void	getCollectionOfEventsCodegen(CodegenMethodNode method, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
void	getCollectionScalarCodegen(CodegenMethodNode method, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
void	getEventBeanCodegen(CodegenMethodNode method, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
void	getGroupKeyCodegen(CodegenMethodNode method, CodegenClassScope classScope)
void	getGroupKeysCodegen(CodegenMethodNode method, CodegenClassScope classScope)
AggregationCodegenRowLevelDesc	getRowLevelDesc()
void	getValueCodegen(CodegenMethodNode method, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
void	isGroupedCodegen(CodegenMethodNode method, CodegenClassScope classScope)
void	makeServiceCodegen(CodegenMethodNode method, CodegenClassScope classScope)
void	rowCtorCodegen(CodegenClassScope classScope, CodegenCtor rowCtor, java.util.List<CodegenTypedParam> rowMembers, CodegenNamedMethods namedMethods)
void	setCurrentAccessCodegen(CodegenMethodNode method, CodegenClassScope classScope)
void	setRemovedCallbackCodegen(CodegenMethodNode method)
void	stopMethodCodegen(AggregationServiceFactoryForge forge, CodegenMethodNode method)

Methods inherited from class java.lang.Object

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

Constructor Detail

AggSvcGroupByWTableForge

public AggSvcGroupByWTableForge(TableService tableService,
                                TableMetadata tableMetadata,
                                TableColumnMethodPair[] methodPairs,
                                AggregationAccessorSlotPairForge[] accessorForges,
                                AggregationAccessorSlotPair[] accessors,
                                boolean join,
                                int[] targetStates,
                                ExprNode[] accessStateExpr,
                                AggregationAgentForge[] agentForges,
                                AggregationAgent[] agents,
                                AggregationGroupByRollupDesc groupByRollupDesc,
                                boolean hasGroupBy)

Method Detail

getAggregationServiceFactory

public AggregationServiceFactory getAggregationServiceFactory(StatementContext stmtContext,
                                                              boolean isFireAndForget)

Specified by:

getAggregationServiceFactory in interface AggregationServiceFactoryForge

getRowLevelDesc

public AggregationCodegenRowLevelDesc getRowLevelDesc()

Specified by:

getRowLevelDesc in interface AggregationServiceFactoryForge

rowCtorCodegen

public void rowCtorCodegen(CodegenClassScope classScope,
                           CodegenCtor rowCtor,
                           java.util.List<CodegenTypedParam> rowMembers,
                           CodegenNamedMethods namedMethods)

Specified by:

rowCtorCodegen in interface AggregationServiceFactoryForge

makeServiceCodegen

public void makeServiceCodegen(CodegenMethodNode method,
                               CodegenClassScope classScope)

Specified by:

makeServiceCodegen in interface AggregationServiceFactoryForge

ctorCodegen

public void ctorCodegen(CodegenCtor ctor,
                        java.util.List<CodegenTypedParam> explicitMembers,
                        CodegenClassScope classScope)

Specified by:

ctorCodegen in interface AggregationServiceFactoryForge

getValueCodegen

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

Specified by:

getValueCodegen in interface AggregationServiceFactoryForge

getCollectionOfEventsCodegen

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

Specified by:

getCollectionOfEventsCodegen in interface AggregationServiceFactoryForge

getEventBeanCodegen

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

Specified by:

getEventBeanCodegen in interface AggregationServiceFactoryForge

getCollectionScalarCodegen

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

Specified by:

getCollectionScalarCodegen in interface AggregationServiceFactoryForge

applyEnterCodegen

public void applyEnterCodegen(CodegenMethodNode method,
                              CodegenClassScope classScope,
                              CodegenNamedMethods namedMethods)

Specified by:

applyEnterCodegen in interface AggregationServiceFactoryForge

applyLeaveCodegen

public void applyLeaveCodegen(CodegenMethodNode method,
                              CodegenClassScope classScope,
                              CodegenNamedMethods namedMethods)

Specified by:

applyLeaveCodegen in interface AggregationServiceFactoryForge

stopMethodCodegen

public void stopMethodCodegen(AggregationServiceFactoryForge forge,
                              CodegenMethodNode method)

Specified by:

stopMethodCodegen in interface AggregationServiceFactoryForge

setRemovedCallbackCodegen

public void setRemovedCallbackCodegen(CodegenMethodNode method)

Specified by:

setRemovedCallbackCodegen in interface AggregationServiceFactoryForge

setCurrentAccessCodegen

public void setCurrentAccessCodegen(CodegenMethodNode method,
                                    CodegenClassScope classScope)

Specified by:

setCurrentAccessCodegen in interface AggregationServiceFactoryForge

clearResultsCodegen

public void clearResultsCodegen(CodegenMethodNode method,
                                CodegenClassScope classScope)

Specified by:

clearResultsCodegen in interface AggregationServiceFactoryForge

acceptCodegen

public void acceptCodegen(CodegenMethodNode method,
                          CodegenClassScope classScope)

Specified by:

acceptCodegen in interface AggregationServiceFactoryForge

getGroupKeysCodegen

public void getGroupKeysCodegen(CodegenMethodNode method,
                                CodegenClassScope classScope)

Specified by:

getGroupKeysCodegen in interface AggregationServiceFactoryForge

getGroupKeyCodegen

public void getGroupKeyCodegen(CodegenMethodNode method,
                               CodegenClassScope classScope)

Specified by:

getGroupKeyCodegen in interface AggregationServiceFactoryForge

acceptGroupDetailCodegen

public void acceptGroupDetailCodegen(CodegenMethodNode method,
                                     CodegenClassScope classScope)

Specified by:

acceptGroupDetailCodegen in interface AggregationServiceFactoryForge

isGroupedCodegen

public void isGroupedCodegen(CodegenMethodNode method,
                             CodegenClassScope classScope)

Specified by:

isGroupedCodegen in interface AggregationServiceFactoryForge

getCodegen

public void getCodegen(AggSvcTableGetterType getterType,
                       CodegenMethodNode method,
                       CodegenClassScope classScope,
                       CodegenNamedMethods namedMethods)