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

Interface AggregationRow

public interface AggregationRow

Field Summary

Fields

Modifier and Type	Field	Description
static final EPTypeClass	EPTYPE

Method Summary

Modifier and Type	Method	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 Details

EPTYPE

static final EPTypeClass EPTYPE

Method Details

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)