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

Interface AggregationRow

public interface AggregationRow

Field Summary

Fields

Modifier and Type	Field and Description
static EPTypeClass	EPTYPE

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 scol, EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)
void	enterAgg(int scol, Object value)
Object	getAccessState(int scol)
Collection<EventBean>	getCollectionOfEvents(int vcol, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
Collection<Object>	getCollectionScalar(int vcol, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
EventBean	getEventBean(int vcol, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
long	getLastUpdateTime()
long	getRefcount()
Object	getValue(int vcol, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
void	increaseRefcount()
void	leaveAccess(int scol, EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)
void	leaveAgg(int scol, Object value)
void	reset(int column)
void	setLastUpdateTime(long currentTime)

Field Detail

EPTYPE

static final EPTypeClass EPTYPE

Method Detail

applyEnter

void applyEnter(EventBean[] eventsPerStream,
                ExprEvaluatorContext exprEvaluatorContext)

applyLeave

void applyLeave(EventBean[] eventsPerStream,
                ExprEvaluatorContext exprEvaluatorContext)

enterAgg

void enterAgg(int scol,
              Object value)

leaveAgg

void leaveAgg(int scol,
              Object value)

enterAccess

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

leaveAccess

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

getAccessState

Object getAccessState(int scol)

clear

void clear()

getValue

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

getCollectionOfEvents

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

getEventBean

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

getCollectionScalar

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

increaseRefcount

void increaseRefcount()

decreaseRefcount

void decreaseRefcount()

getRefcount

long getRefcount()

getLastUpdateTime

long getLastUpdateTime()

setLastUpdateTime

void setLastUpdateTime(long currentTime)

reset

void reset(int column)