com.espertech.esper.epl.agg.codegen

Interface AggregationRowGenerated

public interface AggregationRowGenerated

Method Summary

Modifier and Type	Method and Description
void	applyEnter(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)
void	applyLeave(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)
void	clear()
void	decreaseRefcount()
java.util.Collection<EventBean>	getCollectionOfEvents(int column, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
java.util.Collection<java.lang.Object>	getCollectionScalar(int column, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
EventBean	getEventBean(int column, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
long	getRefcount()
java.lang.Object	getValue(int column, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
void	increaseRefcount()

Method Detail

applyEnter

void applyEnter(EventBean[] eventsPerStream,
                ExprEvaluatorContext exprEvaluatorContext)

applyLeave

void applyLeave(EventBean[] eventsPerStream,
                ExprEvaluatorContext exprEvaluatorContext)

clear

void clear()

getValue

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

getCollectionOfEvents

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

getEventBean

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

getCollectionScalar

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

increaseRefcount

void increaseRefcount()

decreaseRefcount

void decreaseRefcount()

getRefcount

long getRefcount()