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 |
Contains EPL statement specification classes define the constructs that make up an EPL statement,
such as the list of items in the select clause, the insert-into stream name and property names etc.
|
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,
Annotation[] annotations,
StatementAIResourceRegistry statementAgentInstanceRegistry,
StatementAgentInstanceLock defaultAgentInstanceLock,
ContextDescriptor contextDescriptor,
PatternSubexpressionPoolStmtSvc patternSubexpressionPoolSvc,
MatchRecognizeStatePoolStmtSvc matchRecognizeStatePoolStmtSvc,
boolean statelessSelect,
ContextControllerFactoryService contextControllerFactoryService,
AgentInstanceScriptContext defaultAgentInstanceScriptContext,
AggregationServiceFactoryService aggregationServiceFactoryService,
boolean writesToTables,
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,
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(Map<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.
|