com.espertech.esper.common.internal.epl.agg.method.rate

Class AggregatorRateEver

java.lang.Object

com.espertech.esper.common.internal.epl.agg.method.core.AggregatorMethodWDistinctWFilterBase

com.espertech.esper.common.internal.epl.agg.method.rate.AggregatorRateEver

All Implemented Interfaces:

AggregatorMethod

public class AggregatorRateEver
extends AggregatorMethodWDistinctWFilterBase

Aggregation computing an event arrival rate for with and without data window.

Field Summary

Fields

Modifier and Type	Field and Description
protected AggregationForgeFactoryRate	factory
protected CodegenExpressionMember	hasLeave
protected CodegenExpressionMember	points

Fields inherited from class com.espertech.esper.common.internal.epl.agg.method.core.AggregatorMethodWDistinctWFilterBase

distinct, hasFilter, optionalDistinctSerde, optionalDistinctValueType, optionalFilter

Constructor Summary

Constructors

Constructor and Description
AggregatorRateEver(AggregationForgeFactoryRate factory, EPTypeClass optionalDistinctValueType, DataInputOutputSerdeForge optionalDistinctSerde, boolean hasFilter, ExprNode optionalFilter)

Method Summary

Modifier and Type	Method and Description
protected void	appendFormatWODistinct(FabricTypeCollector collector)
protected void	apply(CodegenMethod method, CodegenClassScope classScope)
protected void	applyEvalEnterFiltered(CodegenMethod method, ExprForgeCodegenSymbol symbols, ExprForge[] forges, CodegenClassScope classScope)
void	applyEvalLeaveCodegen(CodegenMethod method, ExprForgeCodegenSymbol symbols, ExprForge[] forges, CodegenClassScope classScope)
protected void	applyEvalLeaveFiltered(CodegenMethod method, ExprForgeCodegenSymbol symbols, ExprForge[] forges, CodegenClassScope classScope)
protected void	applyTableEnterFiltered(CodegenExpressionRef value, EPType[] evaluationTypes, CodegenMethod method, CodegenClassScope classScope)
protected void	applyTableLeaveFiltered(CodegenExpressionRef value, EPType[] evaluationTypes, CodegenMethod method, CodegenClassScope classScope)
protected void	clearWODistinct(CodegenMethod method, CodegenClassScope classScope)
void	getValueCodegen(CodegenMethod method, CodegenClassScope classScope)
void	initForgeFiltered(int col, CodegenCtor rowCtor, CodegenMemberCol membersColumnized, CodegenClassScope classScope)
protected void	readWODistinct(CodegenExpressionRef row, int col, CodegenExpressionRef input, CodegenExpressionRef unitKey, CodegenMethod method, CodegenClassScope classScope)
static boolean	removeFromHead(Deque<Long> points, long timestamp, long interval) NOTE: Code-generation-invoked method, method name and parameter order matters
protected void	writeWODistinct(CodegenExpressionRef row, int col, CodegenExpressionRef output, CodegenExpressionRef unitKey, CodegenExpressionRef writer, CodegenMethod method, CodegenClassScope classScope)

Methods inherited from class com.espertech.esper.common.internal.epl.agg.method.core.AggregatorMethodWDistinctWFilterBase

applyEvalEnterCodegen, applyTableEnterCodegen, applyTableLeaveCodegen, clearCodegen, collectFabricType, initForge, readCodegen, toDistinctValueKey, writeCodegen

Methods inherited from class java.lang.Object

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

Field Detail

factory

protected final AggregationForgeFactoryRate factory

points

protected CodegenExpressionMember points

hasLeave

protected CodegenExpressionMember hasLeave

Constructor Detail

AggregatorRateEver

public AggregatorRateEver(AggregationForgeFactoryRate factory,
                          EPTypeClass optionalDistinctValueType,
                          DataInputOutputSerdeForge optionalDistinctSerde,
                          boolean hasFilter,
                          ExprNode optionalFilter)

Method Detail

initForgeFiltered

public void initForgeFiltered(int col,
                              CodegenCtor rowCtor,
                              CodegenMemberCol membersColumnized,
                              CodegenClassScope classScope)

Specified by:

initForgeFiltered in class AggregatorMethodWDistinctWFilterBase

applyEvalEnterFiltered

protected void applyEvalEnterFiltered(CodegenMethod method,
                                      ExprForgeCodegenSymbol symbols,
                                      ExprForge[] forges,
                                      CodegenClassScope classScope)

Specified by:

applyEvalEnterFiltered in class AggregatorMethodWDistinctWFilterBase

applyEvalLeaveCodegen

public void applyEvalLeaveCodegen(CodegenMethod method,
                                  ExprForgeCodegenSymbol symbols,
                                  ExprForge[] forges,
                                  CodegenClassScope classScope)

Specified by:

applyEvalLeaveCodegen in interface AggregatorMethod

Overrides:

applyEvalLeaveCodegen in class AggregatorMethodWDistinctWFilterBase

applyEvalLeaveFiltered

protected void applyEvalLeaveFiltered(CodegenMethod method,
                                      ExprForgeCodegenSymbol symbols,
                                      ExprForge[] forges,
                                      CodegenClassScope classScope)

Specified by:

applyEvalLeaveFiltered in class AggregatorMethodWDistinctWFilterBase

applyTableEnterFiltered

protected void applyTableEnterFiltered(CodegenExpressionRef value,
                                       EPType[] evaluationTypes,
                                       CodegenMethod method,
                                       CodegenClassScope classScope)

Specified by:

applyTableEnterFiltered in class AggregatorMethodWDistinctWFilterBase

applyTableLeaveFiltered

protected void applyTableLeaveFiltered(CodegenExpressionRef value,
                                       EPType[] evaluationTypes,
                                       CodegenMethod method,
                                       CodegenClassScope classScope)

Specified by:

applyTableLeaveFiltered in class AggregatorMethodWDistinctWFilterBase

clearWODistinct

protected void clearWODistinct(CodegenMethod method,
                               CodegenClassScope classScope)

Specified by:

clearWODistinct in class AggregatorMethodWDistinctWFilterBase

getValueCodegen

public void getValueCodegen(CodegenMethod method,
                            CodegenClassScope classScope)

writeWODistinct

protected void writeWODistinct(CodegenExpressionRef row,
                               int col,
                               CodegenExpressionRef output,
                               CodegenExpressionRef unitKey,
                               CodegenExpressionRef writer,
                               CodegenMethod method,
                               CodegenClassScope classScope)

Specified by:

writeWODistinct in class AggregatorMethodWDistinctWFilterBase

readWODistinct

protected void readWODistinct(CodegenExpressionRef row,
                              int col,
                              CodegenExpressionRef input,
                              CodegenExpressionRef unitKey,
                              CodegenMethod method,
                              CodegenClassScope classScope)

Specified by:

readWODistinct in class AggregatorMethodWDistinctWFilterBase

appendFormatWODistinct

protected void appendFormatWODistinct(FabricTypeCollector collector)

Specified by:

appendFormatWODistinct in class AggregatorMethodWDistinctWFilterBase

removeFromHead

public static boolean removeFromHead(Deque<Long> points,
                                     long timestamp,
                                     long interval)

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

Parameters:

points - points

timestamp - timestamp

interval - interval

Returns:

hasLeave

apply

protected void apply(CodegenMethod method,
                     CodegenClassScope classScope)