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

Class AggSvcGroupByReclaimAgedImpl

java.lang.Object

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

public class AggSvcGroupByReclaimAgedImpl
extends Object

Implementation for handling aggregation with grouping by group-keys.

Field Summary

Fields

Modifier and Type	Field	Description
static final long	DEFAULT_MAX_AGE_MSEC

Constructor Summary

Constructors

Constructor	Description
AggSvcGroupByReclaimAgedImpl()

Method Summary

Modifier and Type	Method	Description
static void	applyEnterCodegenSweep(CodegenMethod method, CodegenClassScope classScope, AggregationClassNames classNames)
static long	computeTimeReclaimAgeFreq(long current, AggSvcGroupByReclaimAgedEvalFunc func, TimeAbacus timeAbacus)	NOTE: Code-generation-invoked method, method name and parameter order matters
static void	ctorCodegenReclaim(CodegenCtor ctor, List<CodegenTypedParam> explicitMembers, CodegenClassScope classScope, CodegenExpression maxAgeFactory, CodegenExpression frequencyFactory)
static void	rowCtorCodegen(CodegenNamedMethods namedMethods, CodegenClassScope classScope, List<CodegenTypedParam> rowMembers)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_MAX_AGE_MSEC

public static final long DEFAULT_MAX_AGE_MSEC

See Also:

• Constant Field Values

Constructor Details

AggSvcGroupByReclaimAgedImpl

public AggSvcGroupByReclaimAgedImpl()

Method Details

rowCtorCodegen

public static void rowCtorCodegen(CodegenNamedMethods namedMethods,
 CodegenClassScope classScope,
 List<CodegenTypedParam> rowMembers)

ctorCodegenReclaim

public static void ctorCodegenReclaim(CodegenCtor ctor,
 List<CodegenTypedParam> explicitMembers,
 CodegenClassScope classScope,
 CodegenExpression maxAgeFactory,
 CodegenExpression frequencyFactory)

applyEnterCodegenSweep

public static void applyEnterCodegenSweep(CodegenMethod method,
 CodegenClassScope classScope,
 AggregationClassNames classNames)

computeTimeReclaimAgeFreq

public static long computeTimeReclaimAgeFreq(long current,
 AggSvcGroupByReclaimAgedEvalFunc func,
 TimeAbacus timeAbacus)

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

Parameters:

current - current

func - func

timeAbacus - abacus

Returns:

delta