com.espertech.esper.common.internal.epl.agg.access.linear

Class AggregationTAAReaderLinearFirstLastIndex

java.lang.Object

com.espertech.esper.common.internal.epl.agg.access.linear.AggregationTAAReaderLinearFirstLastIndex

All Implemented Interfaces:

AggregationMultiFunctionTableReader

public class AggregationTAAReaderLinearFirstLastIndex
extends Object
implements AggregationMultiFunctionTableReader

Constructor Summary

Constructors

Constructor and Description
AggregationTAAReaderLinearFirstLastIndex()

Method Summary

Modifier and Type	Method and Description
Object	getValue(int aggColNum, AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Returns the plain value
Collection	getValueCollectionEvents(int aggColNum, AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Return a collection of events or null when not available.
Collection	getValueCollectionScalar(int aggColNum, AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Return a collection of values or null when not available.
EventBean	getValueEventBean(int aggColNum, AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Returns a single event or null when not available.
void	setAccessType(AggregationAccessorLinearType accessType)
void	setOptionalConstIndex(Integer optionalConstIndex)
void	setOptionalIndexEval(ExprEvaluator optionalIndexEval)

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregationTAAReaderLinearFirstLastIndex

public AggregationTAAReaderLinearFirstLastIndex()

Method Detail

setAccessType

public void setAccessType(AggregationAccessorLinearType accessType)

setOptionalConstIndex

public void setOptionalConstIndex(Integer optionalConstIndex)

setOptionalIndexEval

public void setOptionalIndexEval(ExprEvaluator optionalIndexEval)

getValue

public Object getValue(int aggColNum,
                       AggregationRow row,
                       EventBean[] eventsPerStream,
                       boolean isNewData,
                       ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: AggregationMultiFunctionTableReader

Returns the plain value

Specified by:

getValue in interface AggregationMultiFunctionTableReader

Parameters:

aggColNum - column number

row - aggregation row

eventsPerStream - events

isNewData - new-data flag

exprEvaluatorContext - evaluation context

Returns:

value

getValueCollectionEvents

public Collection getValueCollectionEvents(int aggColNum,
                                           AggregationRow row,
                                           EventBean[] eventsPerStream,
                                           boolean isNewData,
                                           ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: AggregationMultiFunctionTableReader

Return a collection of events or null when not available. The EPType returned by the handler indicates whether the compiler allows operations on events.

Specified by:

getValueCollectionEvents in interface AggregationMultiFunctionTableReader

Parameters:

aggColNum - column number

row - aggregation row

eventsPerStream - events

isNewData - new-data flag

exprEvaluatorContext - evaluation context

Returns:

collection of EventBean

getValueCollectionScalar

public Collection getValueCollectionScalar(int aggColNum,
                                           AggregationRow row,
                                           EventBean[] eventsPerStream,
                                           boolean isNewData,
                                           ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: AggregationMultiFunctionTableReader

Return a collection of values or null when not available. The EPType returned by the handler indicates whether the compiler allows operations on events.

Specified by:

getValueCollectionScalar in interface AggregationMultiFunctionTableReader

Parameters:

aggColNum - column number

row - aggregation row

eventsPerStream - events

isNewData - new-data flag

exprEvaluatorContext - evaluation context

Returns:

collection of values

getValueEventBean

public EventBean getValueEventBean(int aggColNum,
                                   AggregationRow row,
                                   EventBean[] eventsPerStream,
                                   boolean isNewData,
                                   ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: AggregationMultiFunctionTableReader

Returns a single event or null when not available. The EPType returned by the handler indicates whether the compiler allows operations on events.

Specified by:

getValueEventBean in interface AggregationMultiFunctionTableReader

Parameters:

aggColNum - column number

row - aggregation row

eventsPerStream - events

isNewData - new-data flag

exprEvaluatorContext - evaluation context

Returns:

event