com.espertech.esper.epl.agg.access

Class AggregationAccessorMinMaxByNonTable

java.lang.Object

com.espertech.esper.epl.agg.access.AggregationAccessorMinMaxByBase

com.espertech.esper.epl.agg.access.AggregationAccessorMinMaxByNonTable

All Implemented Interfaces:

AggregationAccessor, AggregationAccessorForge

public class AggregationAccessorMinMaxByNonTable
extends AggregationAccessorMinMaxByBase
implements AggregationAccessorForge

Represents the aggregation accessor that provides the result for the "maxBy" aggregation function.

Field Summary

Fields inherited from class com.espertech.esper.epl.agg.access.AggregationAccessorMinMaxByBase

max

Constructor Summary

Constructors

Constructor and Description
AggregationAccessorMinMaxByNonTable(boolean max)

Method Summary

Modifier and Type	Method and Description
AggregationAccessor	getAccessor(EngineImportService engineImportService, boolean isFireAndForget, java.lang.String statementName)
PlugInAggregationMultiFunctionCodegenType	getPluginCodegenType()
java.lang.Object	getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context) Return the aggregation state value either as a scalar value or any other object.
void	getValueCodegen(AggregationAccessorForgeGetCodegenContext context)

Methods inherited from class com.espertech.esper.epl.agg.access.AggregationAccessorMinMaxByBase

getEnumerableEvent, getEnumerableEventCodegen, getEnumerableEvents, getEnumerableEventsCodegen, getEnumerableScalar, getEnumerableScalarCodegen

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.espertech.esper.epl.agg.access.AggregationAccessorForge

getEnumerableEventCodegen, getEnumerableEventsCodegen, getEnumerableScalarCodegen

Constructor Detail

AggregationAccessorMinMaxByNonTable

public AggregationAccessorMinMaxByNonTable(boolean max)

Method Detail

getPluginCodegenType

public PlugInAggregationMultiFunctionCodegenType getPluginCodegenType()

Specified by:

getPluginCodegenType in interface AggregationAccessorForge

getValue

public java.lang.Object getValue(AggregationState state,
                                 EventBean[] eventsPerStream,
                                 boolean isNewData,
                                 ExprEvaluatorContext context)

Description copied from interface: AggregationAccessor

Return the aggregation state value either as a scalar value or any other object.

For enumeration over scalar values or objects return an array or collection of scalar or object values.

Use the #getEnumerableEvents method to return a collection of events.

Use the #getEnumerableEvent to return a single events.

Specified by:

getValue in interface AggregationAccessor

Parameters:

state - aggregation state, downcast as needed

eventsPerStream - events

isNewData - new-data indicator

context - eval context

Returns:

return value

getValueCodegen

public void getValueCodegen(AggregationAccessorForgeGetCodegenContext context)

Specified by:

getValueCodegen in interface AggregationAccessorForge

getAccessor

public AggregationAccessor getAccessor(EngineImportService engineImportService,
                                       boolean isFireAndForget,
                                       java.lang.String statementName)

Specified by:

getAccessor in interface AggregationAccessorForge