Package 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 Details

  • Constructor Details

    • ExpressionViewFactoryBase

      public ExpressionViewFactoryBase()

  • Method Details

    • 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)