com.espertech.esper.epl.agg.access

Class AggregationAccessorLastNoEval

java.lang.Object

com.espertech.esper.epl.agg.access.AggregationAccessorLastNoEval

All Implemented Interfaces:

AggregationAccessor, AggregationAccessorForge

public class AggregationAccessorLastNoEval
extends java.lang.Object
implements AggregationAccessor, AggregationAccessorForge

Field Summary

Fields

Modifier and Type	Field and Description
static AggregationAccessorLastNoEval	INSTANCE

Method Summary

Modifier and Type	Method and Description
AggregationAccessor	getAccessor(EngineImportService engineImportService, boolean isFireAndForget, java.lang.String statementName)
EventBean	getEnumerableEvent(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Return the aggregation state value consisting of a single event.
void	getEnumerableEventCodegen(AggregationAccessorForgeGetCodegenContext context)
java.util.Collection<EventBean>	getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Return the aggregation state value consisting of a collection of events.
void	getEnumerableEventsCodegen(AggregationAccessorForgeGetCodegenContext context)
java.util.Collection<java.lang.Object>	getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Return the aggregation state value consisting of a collection of scalar values.
void	getEnumerableScalarCodegen(AggregationAccessorForgeGetCodegenContext context)
PlugInAggregationMultiFunctionCodegenType	getPluginCodegenType()
java.lang.Object	getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Return the aggregation state value either as a scalar value or any other object.
void	getValueCodegen(AggregationAccessorForgeGetCodegenContext context)

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final AggregationAccessorLastNoEval INSTANCE

Method Detail

getAccessor

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

Specified by:

getAccessor in interface AggregationAccessorForge

getPluginCodegenType

public PlugInAggregationMultiFunctionCodegenType getPluginCodegenType()

Specified by:

getPluginCodegenType in interface AggregationAccessorForge

getValue

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

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

exprEvaluatorContext - eval context

Returns:

return value

getEnumerableEvents

public java.util.Collection<EventBean> getEnumerableEvents(AggregationState state,
                                                           EventBean[] eventsPerStream,
                                                           boolean isNewData,
                                                           ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: AggregationAccessor

Return the aggregation state value consisting of a collection of events.

Specified by:

getEnumerableEvents in interface AggregationAccessor

Parameters:

state - aggregation state, downcast as needed

eventsPerStream - events

isNewData - new-data indicator

exprEvaluatorContext - eval context

Returns:

return collection of events or null or empty collection

getEnumerableScalar

public java.util.Collection<java.lang.Object> getEnumerableScalar(AggregationState state,
                                                                  EventBean[] eventsPerStream,
                                                                  boolean isNewData,
                                                                  ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: AggregationAccessor

Return the aggregation state value consisting of a collection of scalar values.

Specified by:

getEnumerableScalar in interface AggregationAccessor

Parameters:

state - aggregation state, downcast as needed

eventsPerStream - events

isNewData - new-data indicator

exprEvaluatorContext - eval context

Returns:

return collection of scalar or null or empty collection

getEnumerableEvent

public EventBean getEnumerableEvent(AggregationState state,
                                    EventBean[] eventsPerStream,
                                    boolean isNewData,
                                    ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: AggregationAccessor

Return the aggregation state value consisting of a single event.

Specified by:

getEnumerableEvent in interface AggregationAccessor

Parameters:

state - aggregation state, downcast as needed

eventsPerStream - events

isNewData - new-data indicator

exprEvaluatorContext - eval context

Returns:

return event or null

getValueCodegen

public void getValueCodegen(AggregationAccessorForgeGetCodegenContext context)

Specified by:

getValueCodegen in interface AggregationAccessorForge

getEnumerableEventsCodegen

public void getEnumerableEventsCodegen(AggregationAccessorForgeGetCodegenContext context)

Specified by:

getEnumerableEventsCodegen in interface AggregationAccessorForge

getEnumerableEventCodegen

public void getEnumerableEventCodegen(AggregationAccessorForgeGetCodegenContext context)

Specified by:

getEnumerableEventCodegen in interface AggregationAccessorForge

getEnumerableScalarCodegen

public void getEnumerableScalarCodegen(AggregationAccessorForgeGetCodegenContext context)

Specified by:

getEnumerableScalarCodegen in interface AggregationAccessorForge