Package 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
    Description
    EPServicesContextFactoryBase()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    EPServicesContext
    createServicesContext(EPRuntimeSPI epRuntime, com.espertech.esper.common.client.configuration.Configuration configs, EPRuntimeOptions options)
    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, EPRuntimeOptions options, com.espertech.esper.common.internal.context.util.ParentClassLoader classLoaderParent)
     
    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.serde.runtime.event.EventSerdeFactory
    makeEventSerdeFactory(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices ext)
     
    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, com.espertech.esper.common.internal.event.core.EventBeanTypedEventFactory eventBeanTypedEventFactory)
     
    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.serde.runtime.eventtype.EventTypeSerdeRepository
    makeEventTypeSerdeRepository(com.espertech.esper.common.internal.event.eventtyperepo.EventTypeRepository preconfigureds, com.espertech.esper.common.internal.collection.PathRegistry<String,com.espertech.esper.common.client.EventType> eventTypePathRegistry)
     
    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.pattern.pool.PatternSubexpressionPoolRuntimeSvc
    makePatternSubexpressionPoolSvc(long maxSubexpressions, boolean maxSubexpressionPreventStart, com.espertech.esper.common.internal.context.module.RuntimeExtensionServices runtimeExtensionServices)
     
    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, ZoneId zoneId)
     
    protected abstract StageRecoveryService
    makeStageRecoveryService(EPServicesHA epServicesHA)
     
    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 Details

    • EPServicesContextFactoryBase

      public EPServicesContextFactoryBase()

  • Method Details

    • 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, EPRuntimeOptions options, com.espertech.esper.common.internal.context.util.ParentClassLoader classLoaderParent)

    • 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, com.espertech.esper.common.internal.event.core.EventBeanTypedEventFactory eventBeanTypedEventFactory)

    • 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, ZoneId zoneId)

    • 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)

    • 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)

    • makeEventTypeSerdeRepository

      protected abstract com.espertech.esper.common.internal.serde.runtime.eventtype.EventTypeSerdeRepository makeEventTypeSerdeRepository(com.espertech.esper.common.internal.event.eventtyperepo.EventTypeRepository preconfigureds, com.espertech.esper.common.internal.collection.PathRegistry<String,com.espertech.esper.common.client.EventType> eventTypePathRegistry)

    • makeEventSerdeFactory

      protected abstract com.espertech.esper.common.internal.serde.runtime.event.EventSerdeFactory makeEventSerdeFactory(com.espertech.esper.common.internal.context.module.RuntimeExtensionServices ext)

    • makeStageRecoveryService

      protected abstract StageRecoveryService makeStageRecoveryService(EPServicesHA epServicesHA)

    • makePatternSubexpressionPoolSvc

      protected abstract com.espertech.esper.common.internal.epl.pattern.pool.PatternSubexpressionPoolRuntimeSvc makePatternSubexpressionPoolSvc(long maxSubexpressions, boolean maxSubexpressionPreventStart, com.espertech.esper.common.internal.context.module.RuntimeExtensionServices runtimeExtensionServices)

    • createServicesContext

      public EPServicesContext createServicesContext(EPRuntimeSPI epRuntime, com.espertech.esper.common.client.configuration.Configuration configs, EPRuntimeOptions options)
      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
      options - runtime options or null when not provided
      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