com.espertech.esper.core.service

Class StatementLifecycleSvcImpl

java.lang.Object

com.espertech.esper.core.service.StatementLifecycleSvcImpl

All Implemented Interfaces:

StatementLifecycleStmtContextResolver, StatementLifecycleSvc

public class StatementLifecycleSvcImpl
extends Object
implements StatementLifecycleSvc

Provides statement lifecycle services.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StatementLifecycleSvcImpl.EPStatementDesc Statement information.

Field Summary

Fields

Modifier and Type	Field and Description
protected EPServicesContext	services Services context for statement lifecycle management.
protected Map<Integer,StatementLifecycleSvcImpl.EPStatementDesc>	stmtIdToDescMap Maps of statement id to descriptor.
protected Map<String,EPStatement>	stmtNameToStmtMap Map of statement name to statement.

Constructor Summary

Constructors

Constructor and Description
StatementLifecycleSvcImpl(EPServiceProvider epServiceProvider, EPServicesContext services) Ctor.

Method Summary

Modifier and Type	Method and Description
void	addObserver(StatementLifecycleObserver observer) Add an observer to be called back when statement-state or listener/subscriber changes are registered.
protected static StatementSpecCompiled	compile(StatementSpecRaw spec, String eplStatement, StatementContext statementContext, boolean isSubquery, boolean isOnDemandQuery, Annotation[] annotations, List<ExprSubselectNode> subselectNodes, List<ExprDeclaredNode> declaredNodes, Set<ExprTableAccessNode> tableAccessNodes, EPServicesContext servicesContext) Compiles a statement returning the compile (verified, non-serializable) form of a statement.
static SelectClauseSpecCompiled	compileSelectAllowSubselect(SelectClauseSpecRaw spec) Compile a select clause allowing subselects.
EPStatement	createAndStart(StatementSpecRaw statementSpec, String expression, boolean isPattern, String optStatementName, Object userObject, EPIsolationUnitServices isolationUnitServices, Integer optionalStatementId, EPStatementObjectModel optionalModel) Create and start the statement.
protected StatementLifecycleSvcImpl.EPStatementDesc	createStopped(StatementSpecRaw statementSpec, Annotation[] annotations, String expression, boolean isPattern, String statementName, boolean nameProvided, int statementId, Map<String,Object> optAdditionalContext, Object statementUserObject, EPIsolationUnitServices isolationUnitServices, boolean isFailed, EPStatementObjectModel optionalModel) Create stopped statement.
protected StatementLifecycleSvcImpl.EPStatementDesc	createStoppedAssignName(StatementSpecRaw statementSpec, String expression, boolean isPattern, String optStatementName, int statementId, Map<String,Object> optAdditionalContext, Object userObject, EPIsolationUnitServices isolationUnitServices, EPStatementObjectModel optionalModel) Creates and starts statement.
void	destroy() Destroy the service.
void	destroy(int statementId) Destroy statement by statement id.
void	destroyAllStatements() Destroys all started statements.
protected void	destroyInternal(StatementLifecycleSvcImpl.EPStatementDesc desc)
void	dispatchStatementLifecycleEvent(StatementLifecycleEvent theEvent) Dispatch event to observers.
EPStatementSPI	getStatementById(int statementId) Returns the statement given a statement id.
EPStatement	getStatementByName(String name) Returns the statement by the given name, or null if no such statement exists.
StatementContext	getStatementContextById(int statementId)
String	getStatementNameById(int statementId)
String[]	getStatementNames() Returns an array of statement names.
StatementSpecCompiled	getStatementSpec(int statementId)
Map<String,EPStatement>	getStmtNameToStmt()
void	init() Initialized the service before use.
void	removeObserver(StatementLifecycleObserver observer) Remove an observer to be called back when statement-state or listener/subscriber changes are registered.
void	start(int statementId) Start statement by statement id.
void	start(int statementId, StatementLifecycleSvcImpl.EPStatementDesc desc, boolean isNewStatement, boolean isRecoveringStatement, boolean isResilient) Start the given statement.
void	startAllStatements() Starts all stopped statements.
void	stop(int statementId) Stop statement by statement id.
void	stopAllStatements() Stops all started statements.
void	updatedListeners(EPStatement statement, EPStatementListenerSet listeners, boolean isRecovery) Statements indicate that listeners have been added through this method.

Methods inherited from class java.lang.Object

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

Field Detail

services

protected final EPServicesContext services

Services context for statement lifecycle management.

stmtIdToDescMap

protected final Map<Integer,StatementLifecycleSvcImpl.EPStatementDesc> stmtIdToDescMap

Maps of statement id to descriptor.

stmtNameToStmtMap

protected final Map<String,EPStatement> stmtNameToStmtMap

Map of statement name to statement.

Constructor Detail

StatementLifecycleSvcImpl

public StatementLifecycleSvcImpl(EPServiceProvider epServiceProvider,
                                 EPServicesContext services)

Ctor.

Parameters:

epServiceProvider - is the engine instance to hand to statement-aware listeners

services - is engine services

Method Detail

addObserver

public void addObserver(StatementLifecycleObserver observer)

Description copied from interface: StatementLifecycleSvc

Add an observer to be called back when statement-state or listener/subscriber changes are registered.

The observers list is backed by a Set.

Specified by:

addObserver in interface StatementLifecycleSvc

Parameters:

observer - to add

removeObserver

public void removeObserver(StatementLifecycleObserver observer)

Description copied from interface: StatementLifecycleSvc

Remove an observer to be called back when statement-state or listener/subscriber changes are registered.

Specified by:

removeObserver in interface StatementLifecycleSvc

Parameters:

observer - to remove

destroy

public void destroy()

Description copied from interface: StatementLifecycleSvc

Destroy the service.

Specified by:

destroy in interface StatementLifecycleSvc

init

public void init()

Description copied from interface: StatementLifecycleSvc

Initialized the service before use.

Specified by:

init in interface StatementLifecycleSvc

getStmtNameToStmt

public Map<String,EPStatement> getStmtNameToStmt()

Specified by:

getStmtNameToStmt in interface StatementLifecycleSvc

createAndStart

public EPStatement createAndStart(StatementSpecRaw statementSpec,
                                  String expression,
                                  boolean isPattern,
                                  String optStatementName,
                                  Object userObject,
                                  EPIsolationUnitServices isolationUnitServices,
                                  Integer optionalStatementId,
                                  EPStatementObjectModel optionalModel)

Description copied from interface: StatementLifecycleSvc

Create and start the statement.

Specified by:

createAndStart in interface StatementLifecycleSvc

Parameters:

statementSpec - is the statement definition in bean object form, raw unvalidated and unoptimized.

expression - is the expression text

isPattern - is an indicator on whether this is a pattern statement and thus the iterator must return the last result, versus for non-pattern statements the iterator returns view content.

optStatementName - is an optional statement name, null if none was supplied

userObject - the application define user object associated to each statement, if supplied

isolationUnitServices - isolated service services

optionalStatementId - the statement id

optionalModel - model

Returns:

started statement

createStoppedAssignName

protected StatementLifecycleSvcImpl.EPStatementDesc createStoppedAssignName(StatementSpecRaw statementSpec,
                                                                            String expression,
                                                                            boolean isPattern,
                                                                            String optStatementName,
                                                                            int statementId,
                                                                            Map<String,Object> optAdditionalContext,
                                                                            Object userObject,
                                                                            EPIsolationUnitServices isolationUnitServices,
                                                                            EPStatementObjectModel optionalModel)

Creates and starts statement.

Parameters:

statementSpec - defines the statement

expression - is the EPL

isPattern - is true for patterns

optStatementName - is the optional statement name

statementId - is the statement id

optAdditionalContext - additional context for use by the statement context

userObject - the application define user object associated to each statement, if supplied

isolationUnitServices - isolated service services

optionalModel - model

Returns:

started statement

createStopped

protected StatementLifecycleSvcImpl.EPStatementDesc createStopped(StatementSpecRaw statementSpec,
                                                                  Annotation[] annotations,
                                                                  String expression,
                                                                  boolean isPattern,
                                                                  String statementName,
                                                                  boolean nameProvided,
                                                                  int statementId,
                                                                  Map<String,Object> optAdditionalContext,
                                                                  Object statementUserObject,
                                                                  EPIsolationUnitServices isolationUnitServices,
                                                                  boolean isFailed,
                                                                  EPStatementObjectModel optionalModel)

Create stopped statement.

Parameters:

statementSpec - - statement definition

expression - is the expression text

isPattern - is true for patterns, false for non-patterns

statementName - is the statement name assigned or given

statementId - is the statement id

optAdditionalContext - additional context for use by the statement context

statementUserObject - the application define user object associated to each statement, if supplied

isolationUnitServices - isolated service services

isFailed - to start the statement in failed state

nameProvided - true when an explicit statement name is provided

annotations - annotations

optionalModel - model

Returns:

stopped statement

start

public void start(int statementId)

Description copied from interface: StatementLifecycleSvc

Start statement by statement id.

Specified by:

start in interface StatementLifecycleSvc

Parameters:

statementId - of the statement to start.

start

public void start(int statementId,
                  StatementLifecycleSvcImpl.EPStatementDesc desc,
                  boolean isNewStatement,
                  boolean isRecoveringStatement,
                  boolean isResilient)

Start the given statement.

Parameters:

statementId - is the statement id

desc - is the cached statement info

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

isRecoveringStatement - if the statement is recovering or new

isResilient - true if recovering a resilient stmt

stop

public void stop(int statementId)

Description copied from interface: StatementLifecycleSvc

Stop statement by statement id.

Specified by:

stop in interface StatementLifecycleSvc

Parameters:

statementId - of the statement to stop.

destroy

public void destroy(int statementId)

Description copied from interface: StatementLifecycleSvc

Destroy statement by statement id.

Specified by:

destroy in interface StatementLifecycleSvc

Parameters:

statementId - statementId of the statement to destroy

getStatementByName

public EPStatement getStatementByName(String name)

Description copied from interface: StatementLifecycleSvc

Returns the statement by the given name, or null if no such statement exists.

Specified by:

getStatementByName in interface StatementLifecycleSvc

Parameters:

name - is the statement name

Returns:

statement for the given name, or null if no such statement existed

getStatementSpec

public StatementSpecCompiled getStatementSpec(int statementId)

Specified by:

getStatementSpec in interface StatementLifecycleSvc

getStatementById

public EPStatementSPI getStatementById(int statementId)

Returns the statement given a statement id.

Specified by:

getStatementById in interface StatementLifecycleSvc

Parameters:

statementId - is the statement id

Returns:

statement

getStatementContextById

public StatementContext getStatementContextById(int statementId)

Specified by:

getStatementContextById in interface StatementLifecycleStmtContextResolver

getStatementNames

public String[] getStatementNames()

Description copied from interface: StatementLifecycleSvc

Returns an array of statement names. If no statement has been created, an empty array is returned.

Only returns started and stopped statements.

Specified by:

getStatementNames in interface StatementLifecycleSvc

Returns:

statement names

startAllStatements

public void startAllStatements()
                        throws EPException

Description copied from interface: StatementLifecycleSvc

Starts all stopped statements. First statement to fail supplies the exception.

Specified by:

startAllStatements in interface StatementLifecycleSvc

Throws:

EPException - to indicate a start error.

stopAllStatements

public void stopAllStatements()
                       throws EPException

Description copied from interface: StatementLifecycleSvc

Stops all started statements. First statement to fail supplies the exception.

Specified by:

stopAllStatements in interface StatementLifecycleSvc

Throws:

EPException - to indicate a start error.

destroyAllStatements

public void destroyAllStatements()
                          throws EPException

Description copied from interface: StatementLifecycleSvc

Destroys all started statements. First statement to fail supplies the exception.

Specified by:

destroyAllStatements in interface StatementLifecycleSvc

Throws:

EPException - to indicate a start error.

getStatementNameById

public String getStatementNameById(int statementId)

Specified by:

getStatementNameById in interface StatementLifecycleSvc

updatedListeners

public void updatedListeners(EPStatement statement,
                             EPStatementListenerSet listeners,
                             boolean isRecovery)

Description copied from interface: StatementLifecycleSvc

Statements indicate that listeners have been added through this method.

Specified by:

updatedListeners in interface StatementLifecycleSvc

Parameters:

statement - is the statement for which listeners were added

listeners - is the set of listeners after adding the new listener

isRecovery - indicator whether recovering

compile

protected static StatementSpecCompiled compile(StatementSpecRaw spec,
                                               String eplStatement,
                                               StatementContext statementContext,
                                               boolean isSubquery,
                                               boolean isOnDemandQuery,
                                               Annotation[] annotations,
                                               List<ExprSubselectNode> subselectNodes,
                                               List<ExprDeclaredNode> declaredNodes,
                                               Set<ExprTableAccessNode> tableAccessNodes,
                                               EPServicesContext servicesContext)
                                        throws EPStatementException

Compiles a statement returning the compile (verified, non-serializable) form of a statement.

Parameters:

spec - is the statement specification

eplStatement - the statement to compile

statementContext - the statement services

isSubquery - is true for subquery compilation or false for statement compile

annotations - statement annotations

isOnDemandQuery - indicator whether on-demand query

subselectNodes - subselects

declaredNodes - declared expressions

tableAccessNodes - table nodes

servicesContext - services

Returns:

compiled statement

Throws:

EPStatementException - if the statement cannot be compiled

compileSelectAllowSubselect

public static SelectClauseSpecCompiled compileSelectAllowSubselect(SelectClauseSpecRaw spec)
                                                            throws ExprValidationException

Compile a select clause allowing subselects.

Parameters:

spec - to compile

Returns:

select clause compiled

Throws:

ExprValidationException - when validation fails

destroyInternal

protected void destroyInternal(StatementLifecycleSvcImpl.EPStatementDesc desc)

dispatchStatementLifecycleEvent

public void dispatchStatementLifecycleEvent(StatementLifecycleEvent theEvent)

Description copied from interface: StatementLifecycleSvc

Dispatch event to observers.

Specified by:

dispatchStatementLifecycleEvent in interface StatementLifecycleSvc

Parameters:

theEvent - to dispatch