Package | Description |
---|---|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
com.espertech.esper.core.support |
Internal-use-only services for unit and regression testing
|
com.espertech.esper.epl.core.poll |
Polled executions for use with method-invocation joins
|
com.espertech.esper.epl.db |
Database SQL polling views and caches
|
com.espertech.esper.pattern |
Pattern expression tree and pattern state objects, the later resembles pattern expression state for each active
pattern instance
|
com.espertech.esper.schedule |
Package for timer callback scheduling
|
com.espertech.esper.view |
View infrastructure concerned with view creation and destroy, cloning and hooking views trees into filtering.
|
Modifier and Type | Method and Description |
---|---|
ScheduleBucket |
StatementContext.getScheduleBucket()
Returns the schedule bucket for ordering schedule callbacks within this pattern.
|
Constructor and Description |
---|
StatementContext(StatementContextEngineServices stmtEngineServices,
SchedulingService schedulingService,
ScheduleBucket scheduleBucket,
EPStatementHandle epStatementHandle,
ViewResolutionService viewResultionService,
PatternObjectResolutionService patternResolutionService,
StatementExtensionSvcContext statementExtensionSvcContext,
StatementStopService statementStopService,
PatternContextFactory patternContextFactory,
FilterService filterService,
StatementResultService statementResultService,
InternalEventRouteDest internalEventEngineRouteDest,
java.lang.annotation.Annotation[] annotations,
StatementAIResourceRegistry statementAgentInstanceRegistry,
StatementAgentInstanceLock defaultAgentInstanceLock,
ContextDescriptor contextDescriptor,
PatternSubexpressionPoolStmtSvc patternSubexpressionPoolSvc,
MatchRecognizeStatePoolStmtSvc matchRecognizeStatePoolStmtSvc,
boolean statelessSelect,
ContextControllerFactoryService contextControllerFactoryService,
AgentInstanceScriptContext defaultAgentInstanceScriptContext,
AggregationServiceFactoryService aggregationServiceFactoryService,
boolean writesToTables,
java.lang.Object statementUserObject,
StatementSemiAnonymousTypeRegistry statementSemiAnonymousTypeRegistry,
int priority) |
Modifier and Type | Method and Description |
---|---|
ScheduleBucket |
SupportSchedulingServiceImpl.allocateBucket() |
Modifier and Type | Method and Description |
---|---|
static HistoricalEventViewable |
MethodPollingViewableFactory.createPollMethodView(int streamNumber,
MethodStreamSpec methodStreamSpec,
EventAdapterService eventAdapterService,
EPStatementAgentInstanceHandle epStatementAgentInstanceHandle,
EngineImportService engineImportService,
SchedulingService schedulingService,
ScheduleBucket scheduleBucket,
ExprEvaluatorContext exprEvaluatorContext,
VariableService variableService,
java.lang.String contextName,
DataCacheFactory dataCacheFactory,
StatementContext statementContext)
Creates a method-invocation polling view for use as a stream that calls a method, or pulls results from cache.
|
Modifier and Type | Method and Description |
---|---|
DataCache |
DataCacheFactory.getDataCache(ConfigurationDataCache cacheDesc,
StatementContext statementContext,
EPStatementAgentInstanceHandle epStatementAgentInstanceHandle,
SchedulingService schedulingService,
ScheduleBucket scheduleBucket,
int streamNum)
Creates a cache implementation for the strategy as defined by the cache descriptor.
|
protected DataCache |
DataCacheFactory.makeTimeCache(ConfigurationExpiryTimeCache expCache,
StatementContext statementContext,
EPStatementAgentInstanceHandle epStatementAgentInstanceHandle,
SchedulingService schedulingService,
ScheduleBucket scheduleBucket,
int streamNum) |
Constructor and Description |
---|
DatabaseConfigServiceImpl(java.util.Map<java.lang.String,ConfigurationDBRef> mapDatabaseRef,
SchedulingService schedulingService,
ScheduleBucket scheduleBucket,
EngineImportService engineImportService)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
ScheduleBucket |
PatternContext.getScheduleBucket()
Returns the schedule bucket for ordering schedule callbacks within this pattern.
|
Modifier and Type | Method and Description |
---|---|
ScheduleBucket |
SchedulingMgmtServiceImpl.allocateBucket() |
ScheduleBucket |
SchedulingMgmtService.allocateBucket()
Returns a bucket from which slots can be allocated for ordering concurrent callbacks.
|
Modifier and Type | Method and Description |
---|---|
ScheduleBucket |
ViewFactoryContext.getScheduleBucket()
Returns the schedule bucket for ordering schedule callbacks within this pattern.
|