com.espertech.esper.common.internal.view.expression

Class ExpressionViewFactoryBase

java.lang.Object

com.espertech.esper.common.internal.view.expression.ExpressionViewFactoryBase

All Implemented Interfaces:

DataWindowViewFactory, DataWindowViewWithPrevious, ViewFactory

Direct Known Subclasses:

ExpressionBatchViewFactory, ExpressionWindowViewFactory

public abstract class ExpressionViewFactoryBase
extends Object
implements DataWindowViewFactory, DataWindowViewWithPrevious

Base factory for expression-based window and batch view.

Field Summary

Fields

Modifier and Type	Field and Description
protected AggregationResultFutureAssignableWEval	aggregationResultFutureAssignable
protected AggregationServiceFactory	aggregationServiceFactory
protected EventType	builtinMapType
protected EventType	eventType
protected ExprEvaluator	expiryEval
protected int	scheduleCallbackId
protected int	streamNumber
protected Integer	subqueryNumber
protected Variable[]	variables

Fields inherited from interface com.espertech.esper.common.internal.view.core.ViewFactory

EMPTY_ARRAY, EPTYPE, EPTYPEARRAY, EPTYPEARRAYARRAY, SINGLE_ELEMENT_ARRAY

Constructor Summary

Constructors

Constructor and Description
ExpressionViewFactoryBase()

Method Summary

Modifier and Type	Method and Description
AggregationResultFutureAssignableWEval	getAggregationResultFutureAssignable()
AggregationServiceFactory	getAggregationServiceFactory()
EventType	getBuiltinMapType()
EventType	getEventType()
ExprEvaluator	getExpiryEval()
int	getScheduleCallbackId()
int	getStreamNumber()
Integer	getSubqueryNumber()
Variable[]	getVariables()
void	init(ViewFactoryContext viewFactoryContext, EPStatementInitServices services)
void	setAggregationResultFutureAssignable(AggregationResultFutureAssignableWEval aggregationResultFutureAssignable)
void	setAggregationServiceFactory(AggregationServiceFactory aggregationServiceFactory)
void	setBuiltinMapType(EventType builtinMapType)
void	setEventType(EventType eventType)
void	setExpiryEval(ExprEvaluator expiryEval)
void	setScheduleCallbackId(int scheduleCallbackId)
void	setStreamNumber(int streamNumber)
void	setSubqueryNumber(Integer subqueryNumber)
void	setVariables(Variable[] variables)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.espertech.esper.common.internal.view.core.ViewFactory

getViewName, makeView

Methods inherited from interface com.espertech.esper.common.internal.view.core.DataWindowViewWithPrevious

makePreviousGetter

Field Detail

eventType

protected EventType eventType

variables

protected Variable[] variables

builtinMapType

protected EventType builtinMapType

expiryEval

protected ExprEvaluator expiryEval

scheduleCallbackId

protected int scheduleCallbackId

aggregationServiceFactory

protected AggregationServiceFactory aggregationServiceFactory

aggregationResultFutureAssignable

protected AggregationResultFutureAssignableWEval aggregationResultFutureAssignable

subqueryNumber

protected Integer subqueryNumber

streamNumber

protected int streamNumber

Constructor Detail

ExpressionViewFactoryBase

public ExpressionViewFactoryBase()

Method Detail

init

public void init(ViewFactoryContext viewFactoryContext,
                 EPStatementInitServices services)

Specified by:

init in interface ViewFactory

setEventType

public void setEventType(EventType eventType)

Specified by:

setEventType in interface ViewFactory

getEventType

public EventType getEventType()

Specified by:

getEventType in interface ViewFactory

getBuiltinMapType

public EventType getBuiltinMapType()

getExpiryEval

public ExprEvaluator getExpiryEval()

setVariables

public void setVariables(Variable[] variables)

setBuiltinMapType

public void setBuiltinMapType(EventType builtinMapType)

setExpiryEval

public void setExpiryEval(ExprEvaluator expiryEval)

setScheduleCallbackId

public void setScheduleCallbackId(int scheduleCallbackId)

getScheduleCallbackId

public int getScheduleCallbackId()

getAggregationServiceFactory

public AggregationServiceFactory getAggregationServiceFactory()

setAggregationServiceFactory

public void setAggregationServiceFactory(AggregationServiceFactory aggregationServiceFactory)

getAggregationResultFutureAssignable

public AggregationResultFutureAssignableWEval getAggregationResultFutureAssignable()

setAggregationResultFutureAssignable

public void setAggregationResultFutureAssignable(AggregationResultFutureAssignableWEval aggregationResultFutureAssignable)

getVariables

public Variable[] getVariables()

getSubqueryNumber

public Integer getSubqueryNumber()

setSubqueryNumber

public void setSubqueryNumber(Integer subqueryNumber)

getStreamNumber

public int getStreamNumber()

setStreamNumber

public void setStreamNumber(int streamNumber)