com.espertech.esper.core.start

Class EPStatementStartMethodOnTrigger

java.lang.Object

com.espertech.esper.core.start.EPStatementStartMethodBase

com.espertech.esper.core.start.EPStatementStartMethodOnTrigger

All Implemented Interfaces:

EPStatementStartMethod

public class EPStatementStartMethodOnTrigger
extends EPStatementStartMethodBase

Starts and provides the stop method for EPL statements.

Field Summary

Fields

Modifier and Type	Field and Description
static String	INITIAL_VALUE_STREAM_NAME

Fields inherited from class com.espertech.esper.core.start.EPStatementStartMethodBase

statementSpec

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

DEFAULT_AGENT_INSTANCE_ID

Constructor Summary

Constructors

Constructor and Description
EPStatementStartMethodOnTrigger(StatementSpecCompiled statementSpec)

Method Summary

Modifier and Type	Method and Description
EPStatementStartResult	startInternal(EPServicesContext services, StatementContext statementContext, boolean isNewStatement, boolean isRecoveringStatement, boolean isRecoveringResilient)
protected ExprNode	validateJoinNamedWindow(String engineURI, StatementContext statementContext, ExprNodeOrigin exprNodeOrigin, ExprNode deleteJoinExpr, EventType namedWindowType, String namedWindowStreamName, String namedWindowName, EventType filteredType, String filterStreamName, String filteredTypeName, String optionalTableName)

Methods inherited from class com.espertech.esper.core.start.EPStatementStartMethodBase

getDefaultAgentInstanceContext, getDefaultAgentInstanceHandle, getStatementSpec, isQueryPlanLogging, start

Methods inherited from class java.lang.Object

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

Field Detail

INITIAL_VALUE_STREAM_NAME

public static final String INITIAL_VALUE_STREAM_NAME

See Also:

Constant Field Values

Constructor Detail

EPStatementStartMethodOnTrigger

public EPStatementStartMethodOnTrigger(StatementSpecCompiled statementSpec)

Method Detail

startInternal

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

Specified by:

startInternal in class EPStatementStartMethodBase

Throws:

ExprValidationException

ViewProcessingException

validateJoinNamedWindow

protected ExprNode validateJoinNamedWindow(String engineURI,
                                           StatementContext statementContext,
                                           ExprNodeOrigin exprNodeOrigin,
                                           ExprNode deleteJoinExpr,
                                           EventType namedWindowType,
                                           String namedWindowStreamName,
                                           String namedWindowName,
                                           EventType filteredType,
                                           String filterStreamName,
                                           String filteredTypeName,
                                           String optionalTableName)
                                    throws ExprValidationException

Throws:

ExprValidationException