Package | Description |
---|---|
com.espertech.esper.runtime.internal.kernel.faf | |
com.espertech.esper.runtime.internal.kernel.service | |
com.espertech.esper.runtime.internal.kernel.statement | |
com.espertech.esper.runtime.internal.kernel.thread |
This package contains classes to advanced threading options.
|
Modifier and Type | Method and Description |
---|---|
static com.espertech.esper.common.internal.context.query.FAFProvider |
EPRuntimeHelperFAF.queryMethod(com.espertech.esper.common.client.EPCompiled compiled,
EPServicesContext services) |
Constructor and Description |
---|
EPPreparedQueryImpl(AtomicBoolean serviceStatusProvider,
com.espertech.esper.common.internal.epl.fafquery.querymethod.FAFQueryMethodProvider queryMethodProvider,
com.espertech.esper.common.internal.epl.fafquery.querymethod.FAFQueryMethod queryMethod,
EPServicesContext epServicesContext) |
Modifier and Type | Field and Description |
---|---|
protected EPServicesContext |
EPEventServiceImpl.services |
Modifier and Type | Method and Description |
---|---|
EPServicesContext |
EPServicesContextFactoryBase.createServicesContext(EPRuntimeSPI epRuntime,
com.espertech.esper.common.client.configuration.Configuration configs) |
EPServicesContext |
EPServicesContextFactory.createServicesContext(EPRuntimeSPI epRuntime,
com.espertech.esper.common.client.configuration.Configuration configurationSnapshot)
Factory method for a new set of runtime services.
|
EPServicesContext |
StatementResultServiceImpl.getEpServicesContext() |
EPServicesContext |
EPEventServiceImpl.getServices() |
EPServicesContext |
EPRuntimeSPI.getServicesContext() |
EPServicesContext |
EPRuntimeImpl.getServicesContext() |
Modifier and Type | Method and Description |
---|---|
static void |
Undeployer.checkModulePreconditions(String deploymentId,
String moduleName,
DeploymentInternal deployment,
EPServicesContext services) |
EPEventServiceImpl |
EPServicesContextFactoryDefault.createEPRuntime(EPServicesContext services,
AtomicBoolean serviceStatusProvider) |
EPEventServiceImpl |
EPServicesContextFactory.createEPRuntime(EPServicesContext services,
AtomicBoolean serviceStatusProvider) |
static EPStatementSPI |
DeployerStatement.deployStatement(boolean recovery,
com.espertech.esper.common.internal.context.module.StatementLightweight lightweight,
EPServicesContext services,
EPRuntimeSPI epRuntime) |
void |
RuntimeExtensionServicesSPI.init(EPServicesContext servicesContext,
EPEventServiceSPI runtimeSPI,
EPDeploymentServiceSPI adminSPI)
Invoked to initialize extension services after runtime services initialization.
|
void |
RuntimeExtensionServicesNoHA.init(EPServicesContext servicesContext,
EPEventServiceSPI runtimeSPI,
EPDeploymentServiceSPI adminSPI) |
static void |
EPEventServiceImpl.processStatementScheduleMultiple(com.espertech.esper.common.internal.context.util.EPStatementAgentInstanceHandle handle,
Object callbackObject,
EPServicesContext services)
Processing multiple schedule matches for a statement.
|
static void |
EPEventServiceImpl.processStatementScheduleSingle(com.espertech.esper.common.internal.context.util.EPStatementHandleCallbackSchedule handle,
EPServicesContext services)
Processing single schedule matche for a statement.
|
static void |
Undeployer.undeploy(String deploymentId,
Map<Long,com.espertech.esper.common.client.EventType> deploymentTypes,
com.espertech.esper.common.internal.context.util.StatementContext[] reverted,
com.espertech.esper.common.internal.context.module.ModuleProvider moduleProvider,
EPServicesContext services) |
Constructor and Description |
---|
EPContextPartitionServiceImpl(EPServicesContext services) |
EPEventServiceImpl(EPServicesContext services)
Constructor.
|
EPEventTypeServiceImpl(EPServicesContext services) |
EPFireAndForgetServiceImpl(EPServicesContext services,
AtomicBoolean serviceStatusProvider) |
EPMetricsServiceImpl(EPServicesContext services) |
EPVariableServiceImpl(EPServicesContext services) |
StatementResultServiceImpl(com.espertech.esper.common.internal.context.module.StatementInformationalsRuntime statementInformationals,
EPServicesContext epServicesContext) |
Modifier and Type | Method and Description |
---|---|
EPServicesContext |
EPStatementInitServicesImpl.getServicesContext() |
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) |
Modifier and Type | Method and Description |
---|---|
void |
ThreadingServiceImpl.initThreading(EPServicesContext services,
EPEventServiceImpl runtime) |
void |
ThreadingService.initThreading(EPServicesContext services,
EPEventServiceImpl runtime)
Initialize thread pools.
|
Constructor and Description |
---|
InboundUnitSendWrapped(com.espertech.esper.common.client.EventBean theEvent,
EPServicesContext services,
com.espertech.esper.common.internal.event.util.EPRuntimeEventProcessWrapped runtime)
Ctor.
|
TimerUnitMultiple(EPServicesContext services,
EPEventServiceImpl runtime,
com.espertech.esper.common.internal.context.util.EPStatementAgentInstanceHandle handle,
Object callbackObject)
Ctor.
|
TimerUnitSingle(EPServicesContext services,
EPEventServiceImpl runtime,
com.espertech.esper.common.internal.context.util.EPStatementHandleCallbackSchedule handleCallback)
Ctor.
|
Copyright © 2005–2018. All rights reserved.