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

Class AggregationMethodLinearFirstLast

java.lang.Object

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

All Implemented Interfaces:

AggregationMultiFunctionAggregationMethod

public class AggregationMethodLinearFirstLast
extends Object
implements AggregationMultiFunctionAggregationMethod

Field Summary

Fields

Modifier and Type	Field	Description
static final EPTypeClass	EPTYPE

Constructor Summary

Constructors

Constructor	Description
AggregationMethodLinearFirstLast()

Method Summary

Modifier and Type	Method	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	setOptionalEvaluator(ExprEvaluator optionalEvaluator)

Methods inherited from class java.lang.Object

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

Field Details

EPTYPE

public static final EPTypeClass EPTYPE

Constructor Details

AggregationMethodLinearFirstLast

public AggregationMethodLinearFirstLast()

Method Details

setAccessType

public void setAccessType(AggregationAccessorLinearType accessType)

setOptionalEvaluator

public void setOptionalEvaluator(ExprEvaluator optionalEvaluator)

getValue

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

Description copied from interface: AggregationMultiFunctionAggregationMethod

Returns the plain value

Specified by:

getValue in interface AggregationMultiFunctionAggregationMethod

Parameters:

aggColNum - column number

row - aggregation row

eventsPerStream - events

isNewData - new-data flag

exprEvaluatorContext - evaluation context

Returns:

value

getValueCollectionScalar

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

Description copied from interface: AggregationMultiFunctionAggregationMethod

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

Specified by:

getValueCollectionScalar in interface AggregationMultiFunctionAggregationMethod

Parameters:

aggColNum - column number

row - aggregation row

eventsPerStream - events

isNewData - new-data flag

exprEvaluatorContext - evaluation context

Returns:

collection of values

getValueCollectionEvents

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

Description copied from interface: AggregationMultiFunctionAggregationMethod

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

Specified by:

getValueCollectionEvents in interface AggregationMultiFunctionAggregationMethod

Parameters:

aggColNum - column number

row - aggregation row

eventsPerStream - events

isNewData - new-data flag

exprEvaluatorContext - evaluation context

Returns:

collection of EventBean

getValueEventBean

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

Description copied from interface: AggregationMultiFunctionAggregationMethod

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

Specified by:

getValueEventBean in interface AggregationMultiFunctionAggregationMethod

Parameters:

aggColNum - column number

row - aggregation row

eventsPerStream - events

isNewData - new-data flag

exprEvaluatorContext - evaluation context

Returns:

event