com.espertech.esper.common.internal.epl.resultset.rowpergrouprollup

Class ResultSetProcessorRowPerGroupRollupUtil

java.lang.Object

com.espertech.esper.common.internal.epl.resultset.rowpergrouprollup.ResultSetProcessorRowPerGroupRollupUtil

public class ResultSetProcessorRowPerGroupRollupUtil
extends Object

Constructor Summary

Constructors

Constructor and Description
ResultSetProcessorRowPerGroupRollupUtil()

Method Summary

Modifier and Type	Method and Description
static EventsAndSortKeysPair	getOldEventsSortKeys(int oldEventCount, EventArrayAndSortKeyArray rstreamEventSortArrayBuf, OrderByProcessor orderByProcessor, AggregationGroupByRollupDesc rollupDesc)
static ResultSetProcessorGroupedOutputFirstHelper[]	initializeOutputFirstHelpers(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory, ExprEvaluatorContext exprEvaluatorContext, EPType[] groupKeyTypes, AggregationGroupByRollupDesc groupByRollupDesc, OutputConditionPolledFactory outputConditionPolledFactory, StateMgmtSetting outputLimitHelperSettings) NOTE: Code-generation-invoked method, method name and parameter order matters
static Map<Object,EventBean[]>[]	makeGroupRepsPerLevelBuf(int levelCount) NOTE: Code-generation-invoked method, method name and parameter order matters
static EventArrayAndSortKeyArray	makeRStreamSortedArrayBuf(int length, boolean isSorting) NOTE: Code-generation-invoked method, method name and parameter order matters

Methods inherited from class java.lang.Object

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

Constructor Detail

ResultSetProcessorRowPerGroupRollupUtil

public ResultSetProcessorRowPerGroupRollupUtil()

Method Detail

getOldEventsSortKeys

public static EventsAndSortKeysPair getOldEventsSortKeys(int oldEventCount,
                                                         EventArrayAndSortKeyArray rstreamEventSortArrayBuf,
                                                         OrderByProcessor orderByProcessor,
                                                         AggregationGroupByRollupDesc rollupDesc)

makeRStreamSortedArrayBuf

public static EventArrayAndSortKeyArray makeRStreamSortedArrayBuf(int length,
                                                                  boolean isSorting)

NOTE: Code-generation-invoked method, method name and parameter order matters

Parameters:

length - num-levels

isSorting - sorting flag

Returns:

buffer

makeGroupRepsPerLevelBuf

public static Map<Object,EventBean[]>[] makeGroupRepsPerLevelBuf(int levelCount)

NOTE: Code-generation-invoked method, method name and parameter order matters

Parameters:

levelCount - num-levels

Returns:

buffer

initializeOutputFirstHelpers

public static ResultSetProcessorGroupedOutputFirstHelper[] initializeOutputFirstHelpers(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
                                                                                        ExprEvaluatorContext exprEvaluatorContext,
                                                                                        EPType[] groupKeyTypes,
                                                                                        AggregationGroupByRollupDesc groupByRollupDesc,
                                                                                        OutputConditionPolledFactory outputConditionPolledFactory,
                                                                                        StateMgmtSetting outputLimitHelperSettings)

NOTE: Code-generation-invoked method, method name and parameter order matters

Parameters:

resultSetProcessorHelperFactory - helper factory

exprEvaluatorContext - context

groupKeyTypes - types

groupByRollupDesc - rollup into

outputConditionPolledFactory - condition factory

outputLimitHelperSettings - state management settings for output rate limiter

Returns:

helpers