com.espertech.esper.runtime.internal.kernel.service

Class EPServicesContextFactoryBase

java.lang.Object

com.espertech.esper.runtime.internal.kernel.service.EPServicesContextFactoryBase

All Implemented Interfaces:

EPServicesContextFactory

Direct Known Subclasses:

EPServicesContextFactoryDefault

public abstract class EPServicesContextFactoryBase
extends Object
implements EPServicesContextFactory

Constructor Summary

Constructors

Constructor and Description
EPServicesContextFactoryBase()

Method Summary

Modifier and Type	Method and Description
EPServicesContext	createServicesContext(EPRuntimeSPI epRuntime, com.espertech.esper.common.client.configuration.Configuration configs) Factory method for a new set of runtime services.
protected static com.espertech.esper.common.internal.settings.ExceptionHandlingService	initExceptionHandling(String runtimeURI, com.espertech.esper.common.client.configuration.runtime.ConfigurationRuntimeExceptionHandling exceptionHandling, com.espertech.esper.common.client.configuration.runtime.ConfigurationRuntimeConditionHandling conditionHandling, com.espertech.esper.common.client.util.ClassForNameProvider classForNameProvider)
protected abstract EPServicesHA	initHA(String runtimeURI, com.espertech.esper.common.client.configuration.Configuration configurationSnapshot, RuntimeEnvContext runtimeEnvContext, com.espertech.esper.common.internal.util.ManagedReadWriteLock eventProcessingRWLock, com.espertech.esper.common.internal.settings.RuntimeSettingsService runtimeSettingsService)
protected abstract com.espertech.esper.common.internal.context.activator.ViewableActivatorFactory	initViewableActivatorFactory()
protected abstract com.espertech.esper.common.internal.epl.agg.core.AggregationServiceFactoryService	makeAggregationServiceFactoryService(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices runtimeExt)
protected abstract com.espertech.esper.common.internal.context.mgr.ContextServiceFactory	makeContextServiceFactory(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices runtimeExtensionServices)
protected abstract com.espertech.esper.common.internal.epl.dataflow.filtersvcadapter.DataFlowFilterServiceAdapter	makeDataFlowFilterServiceAdapter()
protected abstract EPStatementFactory	makeEPStatementFactory()
protected abstract com.espertech.esper.common.internal.event.core.EventBeanTypedEventFactory	makeEventBeanTypedEventFactory(com.espertech.esper.common.internal.event.avro.EventTypeAvroHandler eventTypeAvroHandler)
protected abstract com.espertech.esper.common.internal.epl.index.base.EventTableIndexService	makeEventTableIndexService(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices ext)
protected abstract com.espertech.esper.common.internal.event.avro.EventTypeAvroHandler	makeEventTypeAvroHandler(com.espertech.esper.common.internal.settings.ClasspathImportServiceRuntime classpathImportServiceRuntime, com.espertech.esper.common.client.configuration.common.ConfigurationCommonEventTypeMeta.AvroSettings avroSettings, com.espertech.esper.common.internal.context.module.RuntimeExtensionServices runtimeExt)
protected abstract com.espertech.esper.common.internal.event.eventtypefactory.EventTypeFactory	makeEventTypeFactory(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices runtimeExt, com.espertech.esper.common.internal.event.eventtyperepo.EventTypeRepositoryImpl eventTypeRepositoryPreconfigured, DeploymentLifecycleServiceImpl deploymentLifecycleService)
protected abstract com.espertech.esper.common.internal.event.core.EventTypeResolvingBeanFactory	makeEventTypeResolvingBeanFactory(com.espertech.esper.common.internal.event.eventtyperepo.EventTypeRepository eventTypeRepository, com.espertech.esper.common.internal.event.avro.EventTypeAvroHandler eventTypeAvroHandler)
protected abstract com.espertech.esper.common.internal.filterspec.FilterBooleanExpressionFactory	makeFilterBooleanExpressionFactory(StatementLifecycleServiceImpl statementLifecycleService)
protected abstract FilterServiceSPI	makeFilterService(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices runtimeExt, com.espertech.esper.common.internal.event.eventtyperepo.EventTypeRepository eventTypeRepository, StatementLifecycleServiceImpl statementLifecycleService, com.espertech.esper.common.internal.settings.RuntimeSettingsService runtimeSettingsService, com.espertech.esper.common.internal.event.core.EventTypeIdResolver eventTypeIdResolver, com.espertech.esper.common.internal.filterspec.FilterSharedLookupableRepository filterSharedLookupableRepository)
protected abstract com.espertech.esper.common.internal.filterspec.FilterSharedBoolExprRepository	makeFilterSharedBoolExprRepository()
protected abstract com.espertech.esper.common.internal.filterspec.FilterSharedLookupableRepository	makeFilterSharedLookupableRepository()
protected abstract com.espertech.esper.common.internal.epl.historical.datacache.HistoricalDataCacheFactory	makeHistoricalDataCacheFactory(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices runtimeExtensionServices)
protected abstract com.espertech.esper.common.internal.statement.multimatch.MultiMatchHandlerFactory	makeMultiMatchHandlerFactory(com.espertech.esper.common.client.configuration.Configuration configurationInformation)
protected abstract com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowConsumerManagementService	makeNamedWindowConsumerManagementService(com.espertech.esper.common.internal.epl.namedwindow.core.NamedWindowManagementService namedWindowManagementService)
protected abstract com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowDispatchService	makeNamedWindowDispatchService(SchedulingServiceSPI schedulingService, com.espertech.esper.common.client.configuration.Configuration configurationSnapshot, com.espertech.esper.common.internal.util.ManagedReadWriteLock eventProcessingRWLock, com.espertech.esper.common.internal.settings.ExceptionHandlingService exceptionHandlingService, com.espertech.esper.common.internal.epl.variable.core.VariableManagementService variableManagementService, com.espertech.esper.common.internal.epl.table.core.TableManagementService tableManagementService, com.espertech.esper.common.internal.metrics.stmtmetrics.MetricReportingService metricReportingService)
protected abstract com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowFactoryService	makeNamedWindowFactoryService()
protected abstract com.espertech.esper.common.internal.epl.pattern.core.PatternFactoryService	makePatternFactoryService()
protected abstract com.espertech.esper.common.internal.epl.resultset.core.ResultSetProcessorHelperFactory	makeResultSetProcessorHelperFactory(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices ext)
protected abstract com.espertech.esper.common.internal.epl.rowrecog.state.RowRecogStateRepoFactory	makeRowRecogStateRepoFactory()
protected abstract com.espertech.esper.common.internal.settings.RuntimeSettingsService	makeRuntimeSettingsService(com.espertech.esper.common.client.configuration.Configuration configurationSnapshot)
protected abstract SchedulingServiceSPI	makeSchedulingService(EPServicesHA epServicesHA, com.espertech.esper.common.internal.schedule.TimeSourceService timeSourceService, com.espertech.esper.common.internal.context.module.RuntimeExtensionServices runtimeExt, com.espertech.esper.common.internal.settings.RuntimeSettingsService runtimeSettingsService, com.espertech.esper.common.internal.context.util.StatementContextResolver statementContextResolver)
protected abstract com.espertech.esper.common.internal.serde.DataInputOutputSerdeProvider	makeSerdeProvider(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices ext)
protected abstract com.espertech.esper.common.internal.statement.resource.StatementResourceHolderBuilder	makeStatementResourceHolderBuilder()
protected abstract com.espertech.esper.common.internal.epl.table.core.TableManagementService	makeTableManagementService(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices runtimeExt, com.espertech.esper.common.internal.epl.table.core.TableExprEvaluatorContext tableExprEvaluatorContext)
protected abstract ThreadingService	makeThreadingService(com.espertech.esper.common.client.configuration.Configuration configs)
protected abstract com.espertech.esper.common.internal.epl.variable.core.VariableManagementService	makeVariableManagementService(com.espertech.esper.common.client.configuration.Configuration configs, SchedulingServiceSPI schedulingService, com.espertech.esper.common.internal.event.core.EventBeanTypedEventFactory eventBeanTypedEventFactory, com.espertech.esper.common.internal.settings.RuntimeSettingsService runtimeSettingsService, EPServicesHA epServicesHA)
protected abstract com.espertech.esper.common.internal.view.core.ViewFactoryService	makeViewFactoryService()
protected abstract com.espertech.esper.common.internal.view.previous.ViewServicePreviousFactory	makeViewServicePreviousFactory(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices ext)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.espertech.esper.runtime.internal.kernel.service.EPServicesContextFactory

createEPRuntime

Constructor Detail

EPServicesContextFactoryBase

public EPServicesContextFactoryBase()

Method Detail

initHA

protected abstract EPServicesHA initHA(String runtimeURI,
                                       com.espertech.esper.common.client.configuration.Configuration configurationSnapshot,
                                       RuntimeEnvContext runtimeEnvContext,
                                       com.espertech.esper.common.internal.util.ManagedReadWriteLock eventProcessingRWLock,
                                       com.espertech.esper.common.internal.settings.RuntimeSettingsService runtimeSettingsService)

initViewableActivatorFactory

protected abstract com.espertech.esper.common.internal.context.activator.ViewableActivatorFactory initViewableActivatorFactory()

makeFilterService

protected abstract FilterServiceSPI makeFilterService(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices runtimeExt,
                                                      com.espertech.esper.common.internal.event.eventtyperepo.EventTypeRepository eventTypeRepository,
                                                      StatementLifecycleServiceImpl statementLifecycleService,
                                                      com.espertech.esper.common.internal.settings.RuntimeSettingsService runtimeSettingsService,
                                                      com.espertech.esper.common.internal.event.core.EventTypeIdResolver eventTypeIdResolver,
                                                      com.espertech.esper.common.internal.filterspec.FilterSharedLookupableRepository filterSharedLookupableRepository)

makeStatementResourceHolderBuilder

protected abstract com.espertech.esper.common.internal.statement.resource.StatementResourceHolderBuilder makeStatementResourceHolderBuilder()

makeRuntimeSettingsService

protected abstract com.espertech.esper.common.internal.settings.RuntimeSettingsService makeRuntimeSettingsService(com.espertech.esper.common.client.configuration.Configuration configurationSnapshot)

makeFilterSharedLookupableRepository

protected abstract com.espertech.esper.common.internal.filterspec.FilterSharedLookupableRepository makeFilterSharedLookupableRepository()

makeFilterSharedBoolExprRepository

protected abstract com.espertech.esper.common.internal.filterspec.FilterSharedBoolExprRepository makeFilterSharedBoolExprRepository()

makeFilterBooleanExpressionFactory

protected abstract com.espertech.esper.common.internal.filterspec.FilterBooleanExpressionFactory makeFilterBooleanExpressionFactory(StatementLifecycleServiceImpl statementLifecycleService)

makeAggregationServiceFactoryService

protected abstract com.espertech.esper.common.internal.epl.agg.core.AggregationServiceFactoryService makeAggregationServiceFactoryService(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices runtimeExt)

makeViewFactoryService

protected abstract com.espertech.esper.common.internal.view.core.ViewFactoryService makeViewFactoryService()

makeEventTypeFactory

protected abstract com.espertech.esper.common.internal.event.eventtypefactory.EventTypeFactory makeEventTypeFactory(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices runtimeExt,
                                                                                                                    com.espertech.esper.common.internal.event.eventtyperepo.EventTypeRepositoryImpl eventTypeRepositoryPreconfigured,
                                                                                                                    DeploymentLifecycleServiceImpl deploymentLifecycleService)

makeEventTypeResolvingBeanFactory

protected abstract com.espertech.esper.common.internal.event.core.EventTypeResolvingBeanFactory makeEventTypeResolvingBeanFactory(com.espertech.esper.common.internal.event.eventtyperepo.EventTypeRepository eventTypeRepository,
                                                                                                                                  com.espertech.esper.common.internal.event.avro.EventTypeAvroHandler eventTypeAvroHandler)

makePatternFactoryService

protected abstract com.espertech.esper.common.internal.epl.pattern.core.PatternFactoryService makePatternFactoryService()

makeSchedulingService

protected abstract SchedulingServiceSPI makeSchedulingService(EPServicesHA epServicesHA,
                                                              com.espertech.esper.common.internal.schedule.TimeSourceService timeSourceService,
                                                              com.espertech.esper.common.internal.context.module.RuntimeExtensionServices runtimeExt,
                                                              com.espertech.esper.common.internal.settings.RuntimeSettingsService runtimeSettingsService,
                                                              com.espertech.esper.common.internal.context.util.StatementContextResolver statementContextResolver)

makeMultiMatchHandlerFactory

protected abstract com.espertech.esper.common.internal.statement.multimatch.MultiMatchHandlerFactory makeMultiMatchHandlerFactory(com.espertech.esper.common.client.configuration.Configuration configurationInformation)

makeContextServiceFactory

protected abstract com.espertech.esper.common.internal.context.mgr.ContextServiceFactory makeContextServiceFactory(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices runtimeExtensionServices)

makeViewServicePreviousFactory

protected abstract com.espertech.esper.common.internal.view.previous.ViewServicePreviousFactory makeViewServicePreviousFactory(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices ext)

makeEPStatementFactory

protected abstract EPStatementFactory makeEPStatementFactory()

makeEventBeanTypedEventFactory

protected abstract com.espertech.esper.common.internal.event.core.EventBeanTypedEventFactory makeEventBeanTypedEventFactory(com.espertech.esper.common.internal.event.avro.EventTypeAvroHandler eventTypeAvroHandler)

makeEventTableIndexService

protected abstract com.espertech.esper.common.internal.epl.index.base.EventTableIndexService makeEventTableIndexService(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices ext)

makeSerdeProvider

protected abstract com.espertech.esper.common.internal.serde.DataInputOutputSerdeProvider makeSerdeProvider(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices ext)

makeResultSetProcessorHelperFactory

protected abstract com.espertech.esper.common.internal.epl.resultset.core.ResultSetProcessorHelperFactory makeResultSetProcessorHelperFactory(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices ext)

makeNamedWindowDispatchService

protected abstract com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowDispatchService makeNamedWindowDispatchService(SchedulingServiceSPI schedulingService,
                                                                                                                                         com.espertech.esper.common.client.configuration.Configuration configurationSnapshot,
                                                                                                                                         com.espertech.esper.common.internal.util.ManagedReadWriteLock eventProcessingRWLock,
                                                                                                                                         com.espertech.esper.common.internal.settings.ExceptionHandlingService exceptionHandlingService,
                                                                                                                                         com.espertech.esper.common.internal.epl.variable.core.VariableManagementService variableManagementService,
                                                                                                                                         com.espertech.esper.common.internal.epl.table.core.TableManagementService tableManagementService,
                                                                                                                                         com.espertech.esper.common.internal.metrics.stmtmetrics.MetricReportingService metricReportingService)

makeNamedWindowConsumerManagementService

protected abstract com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowConsumerManagementService makeNamedWindowConsumerManagementService(com.espertech.esper.common.internal.epl.namedwindow.core.NamedWindowManagementService namedWindowManagementService)

makeNamedWindowFactoryService

protected abstract com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowFactoryService makeNamedWindowFactoryService()

makeRowRecogStateRepoFactory

protected abstract com.espertech.esper.common.internal.epl.rowrecog.state.RowRecogStateRepoFactory makeRowRecogStateRepoFactory()

makeVariableManagementService

protected abstract com.espertech.esper.common.internal.epl.variable.core.VariableManagementService makeVariableManagementService(com.espertech.esper.common.client.configuration.Configuration configs,
                                                                                                                                 SchedulingServiceSPI schedulingService,
                                                                                                                                 com.espertech.esper.common.internal.event.core.EventBeanTypedEventFactory eventBeanTypedEventFactory,
                                                                                                                                 com.espertech.esper.common.internal.settings.RuntimeSettingsService runtimeSettingsService,
                                                                                                                                 EPServicesHA epServicesHA)

makeTableManagementService

protected abstract com.espertech.esper.common.internal.epl.table.core.TableManagementService makeTableManagementService(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices runtimeExt,
                                                                                                                        com.espertech.esper.common.internal.epl.table.core.TableExprEvaluatorContext tableExprEvaluatorContext)

makeEventTypeAvroHandler

protected abstract com.espertech.esper.common.internal.event.avro.EventTypeAvroHandler makeEventTypeAvroHandler(com.espertech.esper.common.internal.settings.ClasspathImportServiceRuntime classpathImportServiceRuntime,
                                                                                                                com.espertech.esper.common.client.configuration.common.ConfigurationCommonEventTypeMeta.AvroSettings avroSettings,
                                                                                                                com.espertech.esper.common.internal.context.module.RuntimeExtensionServices runtimeExt)

makeHistoricalDataCacheFactory

protected abstract com.espertech.esper.common.internal.epl.historical.datacache.HistoricalDataCacheFactory makeHistoricalDataCacheFactory(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices runtimeExtensionServices)

makeDataFlowFilterServiceAdapter

protected abstract com.espertech.esper.common.internal.epl.dataflow.filtersvcadapter.DataFlowFilterServiceAdapter makeDataFlowFilterServiceAdapter()

makeThreadingService

protected abstract ThreadingService makeThreadingService(com.espertech.esper.common.client.configuration.Configuration configs)

createServicesContext

public EPServicesContext createServicesContext(EPRuntimeSPI epRuntime,
                                               com.espertech.esper.common.client.configuration.Configuration configs)

Description copied from interface: EPServicesContextFactory

Factory method for a new set of runtime services.

Specified by:

createServicesContext in interface EPServicesContextFactory

Parameters:

epRuntime - is the runtime instance

configs - is a snapshot of configs at the time of runtime creation

Returns:

services context

initExceptionHandling

protected static com.espertech.esper.common.internal.settings.ExceptionHandlingService initExceptionHandling(String runtimeURI,
                                                                                                             com.espertech.esper.common.client.configuration.runtime.ConfigurationRuntimeExceptionHandling exceptionHandling,
                                                                                                             com.espertech.esper.common.client.configuration.runtime.ConfigurationRuntimeConditionHandling conditionHandling,
                                                                                                             com.espertech.esper.common.client.util.ClassForNameProvider classForNameProvider)
                                                                                                      throws com.espertech.esper.common.client.configuration.ConfigurationException

Throws:

com.espertech.esper.common.client.configuration.ConfigurationException