com.espertech.esper.core.service

Class EPAdministratorIsolatedImpl

java.lang.Object

com.espertech.esper.core.service.EPAdministratorIsolatedImpl

All Implemented Interfaces:

EPAdministratorIsolated, EPAdministratorIsolatedSPI

public class EPAdministratorIsolatedImpl
extends Object
implements EPAdministratorIsolatedSPI

Implementation for the admin interface.

Constructor Summary

Constructors

Constructor and Description
EPAdministratorIsolatedImpl(String isolatedServiceName, EPIsolationUnitServices services, EPServicesContext unisolatedServices, EPRuntimeIsolatedSPI isolatedRuntime) Ctor.

Method Summary

Modifier and Type	Method and Description
void	addStatement(EPStatement stmt) Add a statement to the isolated service.
void	addStatement(EPStatement[] stmt) Add statements to the isolated service.
void	addStatement(String name) Add a statement name to the list of statements held by the isolated service provider.
EPStatement	createEPL(String eplStatement, String statementName, Object userObject) Create and starts an EPL statement.
EPStatement	createEPLStatementId(String eplStatement, String statementName, Object userObject, Integer optionalStatementId)
String[]	getStatementNames() Returns the statement names of all started and stopped statements.
void	removeAllStatements() Remove all statements from isolated services, such as upon destroy.
void	removeStatement(EPStatement stmt) Remove a statement from the isolated service.
void	removeStatement(EPStatement[] stmt) Remove statements from the isolated service.

Methods inherited from class java.lang.Object

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

Constructor Detail

EPAdministratorIsolatedImpl

public EPAdministratorIsolatedImpl(String isolatedServiceName,
                                   EPIsolationUnitServices services,
                                   EPServicesContext unisolatedServices,
                                   EPRuntimeIsolatedSPI isolatedRuntime)

Ctor.

Parameters:

isolatedServiceName - name of the isolated service

services - isolated services

unisolatedServices - engine services

isolatedRuntime - the runtime for this isolated service

Method Detail

createEPL

public EPStatement createEPL(String eplStatement,
                             String statementName,
                             Object userObject)
                      throws EPException

Description copied from interface: EPAdministratorIsolated

Create and starts an EPL statement.

The statement name is optimally a unique name. If a statement of the same name has already been created, the engine assigns a postfix to create a unique statement name.

Accepts an application defined user data object associated with the statement. The user object is a single, unnamed field that is stored with every statement. Applications may put arbitrary objects in this field or a null value.

Specified by:

createEPL in interface EPAdministratorIsolated

Parameters:

eplStatement - is the query language statement

statementName - is the statement name or null if not provided or provided via annotation instead

userObject - is the application-defined user object, or null if none provided

Returns:

EPStatement to poll data from or to add listeners to, or null if provided via annotation

Throws:

EPException - when the expression was not valid

createEPLStatementId

public EPStatement createEPLStatementId(String eplStatement,
                                        String statementName,
                                        Object userObject,
                                        Integer optionalStatementId)
                                 throws EPException

Specified by:

createEPLStatementId in interface EPAdministratorIsolatedSPI

Throws:

EPException

getStatementNames

public String[] getStatementNames()

Description copied from interface: EPAdministratorIsolated

Returns the statement names of all started and stopped statements.

This excludes the name of destroyed statements.

Specified by:

getStatementNames in interface EPAdministratorIsolated

Returns:

statement names

addStatement

public void addStatement(String name)

Description copied from interface: EPAdministratorIsolatedSPI

Add a statement name to the list of statements held by the isolated service provider.

Specified by:

addStatement in interface EPAdministratorIsolatedSPI

Parameters:

name - to add

addStatement

public void addStatement(EPStatement stmt)

Description copied from interface: EPAdministratorIsolated

Add a statement to the isolated service.

Specified by:

addStatement in interface EPAdministratorIsolated

Parameters:

stmt - to add

addStatement

public void addStatement(EPStatement[] stmt)

Description copied from interface: EPAdministratorIsolated

Add statements to the isolated service.

Specified by:

addStatement in interface EPAdministratorIsolated

Parameters:

stmt - to add

removeStatement

public void removeStatement(EPStatement stmt)

Description copied from interface: EPAdministratorIsolated

Remove a statement from the isolated service. This does not change engine state.

Specified by:

removeStatement in interface EPAdministratorIsolated

Parameters:

stmt - to remove

removeStatement

public void removeStatement(EPStatement[] stmt)

Description copied from interface: EPAdministratorIsolated

Remove statements from the isolated service. This does not change engine state.

Specified by:

removeStatement in interface EPAdministratorIsolated

Parameters:

stmt - to remove

removeAllStatements

public void removeAllStatements()

Remove all statements from isolated services, such as upon destroy.