com.espertech.esper.common.internal.epl.agg.core

Interface AggregationRow

public interface AggregationRow

Method Summary

Modifier and Type	Method and Description
void	applyEnter(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)
void	applyLeave(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)
void	clear()
void	decreaseRefcount()
void	enterAccess(int column, EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)
void	enterAgg(int column, Object value)
Object	getAccessState(int column)
Collection<EventBean>	getCollectionOfEvents(int column, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
Collection<Object>	getCollectionScalar(int column, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
EventBean	getEventBean(int column, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
long	getLastUpdateTime()
long	getRefcount()
Object	getValue(int column, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
void	increaseRefcount()
void	leaveAccess(int column, EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)
void	leaveAgg(int column, Object value)
void	setLastUpdateTime(long currentTime)

Method Detail

applyEnter

void applyEnter(EventBean[] eventsPerStream,
                ExprEvaluatorContext exprEvaluatorContext)

applyLeave

void applyLeave(EventBean[] eventsPerStream,
                ExprEvaluatorContext exprEvaluatorContext)

enterAgg

void enterAgg(int column,
              Object value)

leaveAgg

void leaveAgg(int column,
              Object value)

enterAccess

void enterAccess(int column,
                 EventBean[] eventsPerStream,
                 ExprEvaluatorContext exprEvaluatorContext)

leaveAccess

void leaveAccess(int column,
                 EventBean[] eventsPerStream,
                 ExprEvaluatorContext exprEvaluatorContext)

getAccessState

Object getAccessState(int column)

clear

void clear()

getValue

Object getValue(int column,
                EventBean[] eventsPerStream,
                boolean isNewData,
                ExprEvaluatorContext exprEvaluatorContext)

getCollectionOfEvents

Collection<EventBean> getCollectionOfEvents(int column,
                                            EventBean[] eventsPerStream,
                                            boolean isNewData,
                                            ExprEvaluatorContext context)

getEventBean

EventBean getEventBean(int column,
                       EventBean[] eventsPerStream,
                       boolean isNewData,
                       ExprEvaluatorContext context)

getCollectionScalar

Collection<Object> getCollectionScalar(int column,
                                       EventBean[] eventsPerStream,
                                       boolean isNewData,
                                       ExprEvaluatorContext context)

increaseRefcount

void increaseRefcount()

decreaseRefcount

void decreaseRefcount()

getRefcount

long getRefcount()

getLastUpdateTime

long getLastUpdateTime()

setLastUpdateTime

void setLastUpdateTime(long currentTime)