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

Interface AggregationMultiFunctionAccessor

public interface AggregationMultiFunctionAccessor

Accessor for access aggregation functions.

Field Summary

Fields

Modifier and Type	Field and Description
static EPTypeClass	EPTYPE Type information.

Method Summary

Modifier and Type	Method and Description
default EventBean	getEnumerableEvent(AggregationMultiFunctionState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Return the aggregation state value consisting of a single event.
default Collection<EventBean>	getEnumerableEvents(AggregationMultiFunctionState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Return the aggregation state value consisting of a collection of events.
default Collection<Object>	getEnumerableScalar(AggregationMultiFunctionState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Return the aggregation state value consisting of a collection of scalar values.
Object	getValue(AggregationMultiFunctionState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Return the aggregation state value either as a scalar value or any other object.

Field Detail

EPTYPE

static final EPTypeClass EPTYPE

Type information.

Method Detail

getValue

Object getValue(AggregationMultiFunctionState state,
                EventBean[] eventsPerStream,
                boolean isNewData,
                ExprEvaluatorContext exprEvaluatorContext)

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.

Parameters:

state - aggregation state, downcast as needed

eventsPerStream - events

isNewData - new-data indicator

exprEvaluatorContext - eval context

Returns:

return value

getEnumerableEvents

default Collection<EventBean> getEnumerableEvents(AggregationMultiFunctionState state,
                                                  EventBean[] eventsPerStream,
                                                  boolean isNewData,
                                                  ExprEvaluatorContext exprEvaluatorContext)

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

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

getEnumerableEvent

default EventBean getEnumerableEvent(AggregationMultiFunctionState state,
                                     EventBean[] eventsPerStream,
                                     boolean isNewData,
                                     ExprEvaluatorContext exprEvaluatorContext)

Return the aggregation state value consisting of a single event.

Parameters:

state - aggregation state, downcast as needed

eventsPerStream - events

isNewData - new-data indicator

exprEvaluatorContext - eval context

Returns:

return event or null

getEnumerableScalar

default Collection<Object> getEnumerableScalar(AggregationMultiFunctionState state,
                                               EventBean[] eventsPerStream,
                                               boolean isNewData,
                                               ExprEvaluatorContext exprEvaluatorContext)

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

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