com.espertech.esper.runtime.internal.kernel.statement

Class EPStatementInitServicesImpl

java.lang.Object

com.espertech.esper.runtime.internal.kernel.statement.EPStatementInitServicesImpl

All Implemented Interfaces:

com.espertech.esper.common.internal.context.module.EPStatementInitServices

public class EPStatementInitServicesImpl
extends Object
implements com.espertech.esper.common.internal.context.module.EPStatementInitServices

Field Summary

Fields inherited from interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

GETAGGREGATIONSERVICEFACTORYSERVICE, GETCLASSPATHIMPORTSERVICERUNTIME, GETCONTEXTSERVICEFACTORY, GETDATAINPUTOUTPUTSERDEPROVIDER, GETEVENTBEANTYPEDEVENTFACTORY, GETEVENTTABLEINDEXSERVICE, GETEVENTTYPERESOLVER, GETFILTERBOOLEANEXPRESSIONFACTORY, GETFILTERSHAREDBOOLEXPRREGISTERY, GETFILTERSHAREDLOOKUPABLEREGISTERY, GETFILTERSPECACTIVATABLEREGISTRY, GETINTERNALEVENTROUTEDEST, GETPATTERNFACTORYSERVICE, GETRESULTSETPROCESSORHELPERFACTORY, GETRUNTIMESETTINGSSERVICE, GETSTATEMENTRESULTSERVICE, GETTIMEPROVIDER, GETVIEWABLEACTIVATORFACTORY, GETVIEWFACTORYSERVICE, REF

Constructor Summary

Constructors

Constructor and Description

EPStatementInitServicesImpl(String statementName, Map<com.espertech.esper.common.client.util.StatementProperty,Object> statementProperties, Annotation[] annotations, String deploymentId, com.espertech.esper.common.internal.event.path.EventTypeResolver eventTypeResolver, com.espertech.esper.common.internal.filterspec.FilterSpecActivatableRegistry filterSpecActivatableRegistry, com.espertech.esper.common.internal.filterspec.FilterSharedBoolExprRegistery filterSharedBoolExprRegistery, com.espertech.esper.common.internal.filterspec.FilterSharedLookupableRegistery filterSharedLookupableRegistery, com.espertech.esper.common.internal.context.aifactory.core.ModuleIncidentals moduleIncidentals, boolean recovery, com.espertech.esper.common.internal.statement.resource.StatementResourceService statementResourceService, com.espertech.esper.common.internal.context.util.StatementResultService statementResultService, EPServicesContext servicesContext)

Method Summary

Modifier and Type	Method and Description
void	activateContext(String name, com.espertech.esper.common.internal.context.controller.core.ContextDefinition definition)
void	activateExpression(String name)
void	activateNamedWindow(String name)
void	activateTable(String name)
void	activateVariable(String name)
void	addReadyCallback(com.espertech.esper.common.internal.context.module.StatementReadyCallback readyCallback)
com.espertech.esper.common.internal.epl.agg.core.AggregationServiceFactoryService	getAggregationServiceFactoryService()
Annotation[]	getAnnotations()
com.espertech.esper.common.internal.settings.ClasspathImportServiceRuntime	getClasspathImportServiceRuntime()
com.espertech.esper.common.internal.context.mgr.ContextManagementService	getContextManagementService()
com.espertech.esper.common.internal.context.mgr.ContextServiceFactory	getContextServiceFactory()
com.espertech.esper.common.internal.serde.DataInputOutputSerdeProvider	getDataInputOutputSerdeProvider()
String	getDeploymentId()
com.espertech.esper.common.internal.event.core.EventBeanTypedEventFactory	getEventBeanTypedEventFactory()
com.espertech.esper.common.internal.epl.index.base.EventTableIndexService	getEventTableIndexService()
com.espertech.esper.common.internal.event.avro.EventTypeAvroHandler	getEventTypeAvroHandler()
com.espertech.esper.common.internal.event.path.EventTypeResolver	getEventTypeResolver()
com.espertech.esper.common.internal.settings.ExceptionHandlingService	getExceptionHandlingService()
com.espertech.esper.common.internal.collection.PathRegistry<String,com.espertech.esper.common.internal.compile.stage1.spec.ExpressionDeclItem>	getExprDeclaredPathRegistry()
com.espertech.esper.common.internal.filterspec.FilterBooleanExpressionFactory	getFilterBooleanExpressionFactory()
com.espertech.esper.common.internal.filterspec.FilterSharedBoolExprRegistery	getFilterSharedBoolExprRegistery()
com.espertech.esper.common.internal.filterspec.FilterSharedLookupableRegistery	getFilterSharedLookupableRegistery()
com.espertech.esper.common.internal.filterspec.FilterSpecActivatableRegistry	getFilterSpecActivatableRegistry()
com.espertech.esper.common.internal.context.util.InternalEventRouteDest	getInternalEventRouteDest()
com.espertech.esper.common.internal.context.aifactory.core.ModuleIncidentals	getModuleIncidentals()
com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowDispatchService	getNamedWindowDispatchService()
com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowFactoryService	getNamedWindowFactoryService()
com.espertech.esper.common.internal.epl.namedwindow.core.NamedWindowManagementService	getNamedWindowManagementService()
com.espertech.esper.common.internal.collection.PathRegistry<String,com.espertech.esper.common.internal.epl.namedwindow.path.NamedWindowMetaData>	getNamedWindowPathRegistry()
com.espertech.esper.common.internal.epl.pattern.core.PatternFactoryService	getPatternFactoryService()
List<com.espertech.esper.common.internal.context.module.StatementReadyCallback>	getReadyCallbacks()
com.espertech.esper.common.internal.epl.resultset.core.ResultSetProcessorHelperFactory	getResultSetProcessorHelperFactory()
com.espertech.esper.common.internal.context.module.RuntimeExtensionServices	getRuntimeExtensionServices()
com.espertech.esper.common.internal.settings.RuntimeSettingsService	getRuntimeSettingsService()
String	getRuntimeURI()
EPServicesContext	getServicesContext()
String	getStatementName()
Map<com.espertech.esper.common.client.util.StatementProperty,Object>	getStatementProperties()
com.espertech.esper.common.internal.statement.resource.StatementResourceService	getStatementResourceService()
com.espertech.esper.common.internal.context.util.StatementResultService	getStatementResultService()
com.espertech.esper.common.internal.epl.table.core.TableManagementService	getTableManagementService()
com.espertech.esper.common.internal.collection.PathRegistry<String,com.espertech.esper.common.internal.epl.table.compiletime.TableMetaData>	getTablePathRegistry()
com.espertech.esper.common.internal.epl.expression.time.abacus.TimeAbacus	getTimeAbacus()
com.espertech.esper.common.internal.schedule.TimeProvider	getTimeProvider()
com.espertech.esper.common.internal.schedule.TimeSourceService	getTimeSourceService()
com.espertech.esper.common.internal.epl.variable.core.VariableManagementService	getVariableManagementService()
com.espertech.esper.common.internal.collection.PathRegistry<String,com.espertech.esper.common.internal.epl.variable.compiletime.VariableMetaData>	getVariablePathRegistry()
com.espertech.esper.common.internal.context.activator.ViewableActivatorFactory	getViewableActivatorFactory()
com.espertech.esper.common.internal.view.core.ViewFactoryService	getViewFactoryService()
boolean	isRecovery()

Methods inherited from class java.lang.Object

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

Constructor Detail

EPStatementInitServicesImpl

public EPStatementInitServicesImpl(String statementName,
                                   Map<com.espertech.esper.common.client.util.StatementProperty,Object> statementProperties,
                                   Annotation[] annotations,
                                   String deploymentId,
                                   com.espertech.esper.common.internal.event.path.EventTypeResolver eventTypeResolver,
                                   com.espertech.esper.common.internal.filterspec.FilterSpecActivatableRegistry filterSpecActivatableRegistry,
                                   com.espertech.esper.common.internal.filterspec.FilterSharedBoolExprRegistery filterSharedBoolExprRegistery,
                                   com.espertech.esper.common.internal.filterspec.FilterSharedLookupableRegistery filterSharedLookupableRegistery,
                                   com.espertech.esper.common.internal.context.aifactory.core.ModuleIncidentals moduleIncidentals,
                                   boolean recovery,
                                   com.espertech.esper.common.internal.statement.resource.StatementResourceService statementResourceService,
                                   com.espertech.esper.common.internal.context.util.StatementResultService statementResultService,
                                   EPServicesContext servicesContext)

Method Detail

getAggregationServiceFactoryService

public com.espertech.esper.common.internal.epl.agg.core.AggregationServiceFactoryService getAggregationServiceFactoryService()

Specified by:

getAggregationServiceFactoryService in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getAnnotations

public Annotation[] getAnnotations()

Specified by:

getAnnotations in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getContextServiceFactory

public com.espertech.esper.common.internal.context.mgr.ContextServiceFactory getContextServiceFactory()

Specified by:

getContextServiceFactory in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getDeploymentId

public String getDeploymentId()

Specified by:

getDeploymentId in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getEventBeanTypedEventFactory

public com.espertech.esper.common.internal.event.core.EventBeanTypedEventFactory getEventBeanTypedEventFactory()

Specified by:

getEventBeanTypedEventFactory in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getClasspathImportServiceRuntime

public com.espertech.esper.common.internal.settings.ClasspathImportServiceRuntime getClasspathImportServiceRuntime()

Specified by:

getClasspathImportServiceRuntime in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getRuntimeURI

public String getRuntimeURI()

Specified by:

getRuntimeURI in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getRuntimeSettingsService

public com.espertech.esper.common.internal.settings.RuntimeSettingsService getRuntimeSettingsService()

Specified by:

getRuntimeSettingsService in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getRuntimeExtensionServices

public com.espertech.esper.common.internal.context.module.RuntimeExtensionServices getRuntimeExtensionServices()

Specified by:

getRuntimeExtensionServices in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getEventTableIndexService

public com.espertech.esper.common.internal.epl.index.base.EventTableIndexService getEventTableIndexService()

Specified by:

getEventTableIndexService in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getEventTypeAvroHandler

public com.espertech.esper.common.internal.event.avro.EventTypeAvroHandler getEventTypeAvroHandler()

Specified by:

getEventTypeAvroHandler in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getExceptionHandlingService

public com.espertech.esper.common.internal.settings.ExceptionHandlingService getExceptionHandlingService()

Specified by:

getExceptionHandlingService in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getFilterSharedLookupableRegistery

public com.espertech.esper.common.internal.filterspec.FilterSharedLookupableRegistery getFilterSharedLookupableRegistery()

Specified by:

getFilterSharedLookupableRegistery in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getFilterSharedBoolExprRegistery

public com.espertech.esper.common.internal.filterspec.FilterSharedBoolExprRegistery getFilterSharedBoolExprRegistery()

Specified by:

getFilterSharedBoolExprRegistery in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getServicesContext

public EPServicesContext getServicesContext()

getNamedWindowDispatchService

public com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowDispatchService getNamedWindowDispatchService()

Specified by:

getNamedWindowDispatchService in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getNamedWindowFactoryService

public com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowFactoryService getNamedWindowFactoryService()

Specified by:

getNamedWindowFactoryService in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getNamedWindowManagementService

public com.espertech.esper.common.internal.epl.namedwindow.core.NamedWindowManagementService getNamedWindowManagementService()

Specified by:

getNamedWindowManagementService in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getPatternFactoryService

public com.espertech.esper.common.internal.epl.pattern.core.PatternFactoryService getPatternFactoryService()

Specified by:

getPatternFactoryService in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getStatementResultService

public com.espertech.esper.common.internal.context.util.StatementResultService getStatementResultService()

Specified by:

getStatementResultService in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getContextManagementService

public com.espertech.esper.common.internal.context.mgr.ContextManagementService getContextManagementService()

Specified by:

getContextManagementService in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getDataInputOutputSerdeProvider

public com.espertech.esper.common.internal.serde.DataInputOutputSerdeProvider getDataInputOutputSerdeProvider()

Specified by:

getDataInputOutputSerdeProvider in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getExprDeclaredPathRegistry

public com.espertech.esper.common.internal.collection.PathRegistry<String,com.espertech.esper.common.internal.compile.stage1.spec.ExpressionDeclItem> getExprDeclaredPathRegistry()

Specified by:

getExprDeclaredPathRegistry in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getEventTypeResolver

public com.espertech.esper.common.internal.event.path.EventTypeResolver getEventTypeResolver()

Specified by:

getEventTypeResolver in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getFilterSpecActivatableRegistry

public com.espertech.esper.common.internal.filterspec.FilterSpecActivatableRegistry getFilterSpecActivatableRegistry()

Specified by:

getFilterSpecActivatableRegistry in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getFilterBooleanExpressionFactory

public com.espertech.esper.common.internal.filterspec.FilterBooleanExpressionFactory getFilterBooleanExpressionFactory()

Specified by:

getFilterBooleanExpressionFactory in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getInternalEventRouteDest

public com.espertech.esper.common.internal.context.util.InternalEventRouteDest getInternalEventRouteDest()

Specified by:

getInternalEventRouteDest in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getModuleIncidentals

public com.espertech.esper.common.internal.context.aifactory.core.ModuleIncidentals getModuleIncidentals()

getNamedWindowPathRegistry

public com.espertech.esper.common.internal.collection.PathRegistry<String,com.espertech.esper.common.internal.epl.namedwindow.path.NamedWindowMetaData> getNamedWindowPathRegistry()

Specified by:

getNamedWindowPathRegistry in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

addReadyCallback

public void addReadyCallback(com.espertech.esper.common.internal.context.module.StatementReadyCallback readyCallback)

Specified by:

addReadyCallback in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getReadyCallbacks

public List<com.espertech.esper.common.internal.context.module.StatementReadyCallback> getReadyCallbacks()

isRecovery

public boolean isRecovery()

getResultSetProcessorHelperFactory

public com.espertech.esper.common.internal.epl.resultset.core.ResultSetProcessorHelperFactory getResultSetProcessorHelperFactory()

Specified by:

getResultSetProcessorHelperFactory in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getStatementResourceService

public com.espertech.esper.common.internal.statement.resource.StatementResourceService getStatementResourceService()

Specified by:

getStatementResourceService in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getTableManagementService

public com.espertech.esper.common.internal.epl.table.core.TableManagementService getTableManagementService()

Specified by:

getTableManagementService in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getTablePathRegistry

public com.espertech.esper.common.internal.collection.PathRegistry<String,com.espertech.esper.common.internal.epl.table.compiletime.TableMetaData> getTablePathRegistry()

Specified by:

getTablePathRegistry in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getTimeAbacus

public com.espertech.esper.common.internal.epl.expression.time.abacus.TimeAbacus getTimeAbacus()

Specified by:

getTimeAbacus in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getTimeProvider

public com.espertech.esper.common.internal.schedule.TimeProvider getTimeProvider()

Specified by:

getTimeProvider in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getTimeSourceService

public com.espertech.esper.common.internal.schedule.TimeSourceService getTimeSourceService()

Specified by:

getTimeSourceService in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getVariableManagementService

public com.espertech.esper.common.internal.epl.variable.core.VariableManagementService getVariableManagementService()

Specified by:

getVariableManagementService in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getVariablePathRegistry

public com.espertech.esper.common.internal.collection.PathRegistry<String,com.espertech.esper.common.internal.epl.variable.compiletime.VariableMetaData> getVariablePathRegistry()

Specified by:

getVariablePathRegistry in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getViewableActivatorFactory

public com.espertech.esper.common.internal.context.activator.ViewableActivatorFactory getViewableActivatorFactory()

Specified by:

getViewableActivatorFactory in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getViewFactoryService

public com.espertech.esper.common.internal.view.core.ViewFactoryService getViewFactoryService()

Specified by:

getViewFactoryService in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

activateNamedWindow

public void activateNamedWindow(String name)

Specified by:

activateNamedWindow in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

activateTable

public void activateTable(String name)

Specified by:

activateTable in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

activateContext

public void activateContext(String name,
                            com.espertech.esper.common.internal.context.controller.core.ContextDefinition definition)

Specified by:

activateContext in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

activateVariable

public void activateVariable(String name)

Specified by:

activateVariable in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

activateExpression

public void activateExpression(String name)

Specified by:

activateExpression in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getStatementName

public String getStatementName()

Specified by:

getStatementName in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices

getStatementProperties

public Map<com.espertech.esper.common.client.util.StatementProperty,Object> getStatementProperties()

Specified by:

getStatementProperties in interface com.espertech.esper.common.internal.context.module.EPStatementInitServices