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 Object
implements EPStatementStartMethod

Starts and provides the stop method for EPL statements.

Field Summary

Fields

Modifier and Type	Field and Description
protected StatementSpecCompiled	statementSpec

Fields inherited from interface com.espertech.esper.core.start.EPStatementStartMethod

DEFAULT_AGENT_INSTANCE_ID

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	EPStatementStartMethodBase(StatementSpecCompiled statementSpec)

Method Summary

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

Parameters:

services - services

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:

ExprValidationException - validation exception

ViewProcessingException - when views cannot be started

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)