com.espertech.esper.epl.agg.access

Class AggregationAccessorMinMaxByBase

java.lang.Object

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

All Implemented Interfaces:

AggregationAccessor

Direct Known Subclasses:

AggregationAccessorMinMaxByNonTable, AggregationAccessorMinMaxByTable

public abstract class AggregationAccessorMinMaxByBase
extends java.lang.Object
implements AggregationAccessor

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

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	max

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AggregationAccessorMinMaxByBase(boolean max)

Method Summary

Modifier and Type	Method and Description
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 context) 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)

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.AggregationAccessor

getValue

Field Detail

max

protected final boolean max

Constructor Detail

AggregationAccessorMinMaxByBase

protected AggregationAccessorMinMaxByBase(boolean max)

Method Detail

getEnumerableEvents

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

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

context - eval context

Returns:

return collection of events or null or empty collection

getEnumerableEventsCodegen

public void getEnumerableEventsCodegen(AggregationAccessorForgeGetCodegenContext context)

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

getEnumerableScalarCodegen

public void getEnumerableScalarCodegen(AggregationAccessorForgeGetCodegenContext context)

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

getEnumerableEventCodegen

public void getEnumerableEventCodegen(AggregationAccessorForgeGetCodegenContext context)