com.espertech.esper.common.client.hook.aggmultifunc

Interface AggregationMultiFunctionTableReader

All Known Implementing Classes:

AggregationTAAReaderLinearFirstLast, AggregationTAAReaderLinearFirstLastIndex, AggregationTAAReaderLinearWindow, AggregationTAAReaderSortedMinMaxBy, AggregationTAAReaderSortedWindow, AgregationTAAReaderCountMinSketchFreq, AgregationTAAReaderCountMinSketchTopK

public interface AggregationMultiFunctionTableReader

Reader for aggregation multi-function state held by a table column.

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.

Method Detail

getValue

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

Returns the plain value

Parameters:

aggColNum - column number

row - aggregation row

eventsPerStream - events

isNewData - new-data flag

exprEvaluatorContext - evaluation context

Returns:

value

getValueCollectionEvents

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

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

Parameters:

aggColNum - column number

row - aggregation row

eventsPerStream - events

isNewData - new-data flag

exprEvaluatorContext - evaluation context

Returns:

collection of EventBean

getValueCollectionScalar

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

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

Parameters:

aggColNum - column number

row - aggregation row

eventsPerStream - events

isNewData - new-data flag

exprEvaluatorContext - evaluation context

Returns:

collection of values

getValueEventBean

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

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

Parameters:

aggColNum - column number

row - aggregation row

eventsPerStream - events

isNewData - new-data flag

exprEvaluatorContext - evaluation context

Returns:

event