com.espertech.esper.core.start
Class EPStatementStartMethodBase

java.lang.Object
  com.espertech.esper.core.start.EPStatementStartMethodBase

All Implemented Interfaces:

EPStatementStartMethod

Direct Known Subclasses:

EPStatementStartMethodCreateContext, EPStatementStartMethodCreateExpression, EPStatementStartMethodCreateGraph, EPStatementStartMethodCreateIndex, EPStatementStartMethodCreateSchema, EPStatementStartMethodCreateTable, EPStatementStartMethodCreateVariable, EPStatementStartMethodCreateWindow, EPStatementStartMethodOnTrigger, EPStatementStartMethodSelect, EPStatementStartMethodUpdate

public abstract class EPStatementStartMethodBase
extends java.lang.Object
implements EPStatementStartMethod

Starts and provides the stop method for EPL statements.

Field Summary

protected StatementSpecCompiled

statementSpec

Constructor Summary

protected

EPStatementStartMethodBase(StatementSpecCompiled statementSpec)

Method Summary

protected AgentInstanceContext	getDefaultAgentInstanceContext(StatementContext statementContext)
protected EPStatementAgentInstanceHandle	getDefaultAgentInstanceHandle(StatementContext statementContext)
StatementSpecCompiled	getStatementSpec()
protected boolean	isQueryPlanLogging(EPServicesContext services)
EPStatementStartResult	start(EPServicesContext services, StatementContext statementContext, boolean isNewStatement, boolean isRecoveringStatement, boolean isRecoveringResilient) Starts the EPL statement.
abstract EPStatementStartResult	startInternal(EPServicesContext services, StatementContext statementContext, boolean isNewStatement, boolean isRecoveringStatement, boolean isRecoveringResilient)

Methods inherited from class java.lang.Object

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

Field Detail

statementSpec

protected final StatementSpecCompiled statementSpec

Constructor Detail

EPStatementStartMethodBase

protected EPStatementStartMethodBase(StatementSpecCompiled statementSpec)

Method Detail

getStatementSpec

public StatementSpecCompiled getStatementSpec()

Specified by:

getStatementSpec in interface EPStatementStartMethod

startInternal

public abstract EPStatementStartResult startInternal(EPServicesContext services,
                                                     StatementContext statementContext,
                                                     boolean isNewStatement,
                                                     boolean isRecoveringStatement,
                                                     boolean isRecoveringResilient)
                                              throws ExprValidationException,
                                                     ViewProcessingException

Throws:

ExprValidationException

ViewProcessingException

start

public EPStatementStartResult start(EPServicesContext services,
                                    StatementContext statementContext,
                                    boolean isNewStatement,
                                    boolean isRecoveringStatement,
                                    boolean isRecoveringResilient)
                             throws ExprValidationException,
                                    ViewProcessingException

Description copied from interface: EPStatementStartMethod

Starts the EPL statement.

Specified by:

start in interface EPStatementStartMethod

statementContext - statement level services

isNewStatement - indicator whether the statement is new or a stop-restart statement

isRecoveringStatement - true to indicate the statement is in the process of being recovered

isRecoveringResilient - true to indicate the statement is in the process of being recovered and that statement is resilient @throws com.espertech.esper.epl.expression.ExprValidationException when the expression validation fails

Returns:

a viewable to attach to for listening to events, and a stop method to invoke to clean up

Throws:

ViewProcessingException - when views cannot be started

ExprValidationException

getDefaultAgentInstanceHandle

protected EPStatementAgentInstanceHandle getDefaultAgentInstanceHandle(StatementContext statementContext)
                                                                throws ExprValidationException

Throws:

ExprValidationException

getDefaultAgentInstanceContext

protected AgentInstanceContext getDefaultAgentInstanceContext(StatementContext statementContext)
                                                       throws ExprValidationException

Throws:

ExprValidationException

isQueryPlanLogging

protected boolean isQueryPlanLogging(EPServicesContext services)