Package | Description |
---|---|
com.espertech.esper.core.context.mgr |
Context management.
|
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.epl.named |
Named window classes are in this package
|
com.espertech.esper.epl.parse |
Parsers and AST tree walkers and helper classes transforming AST into business objects
|
com.espertech.esper.epl.spec |
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.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 |
---|---|
SchedulingService |
ContextControllerInitTermFactoryBase.getSchedulingService() |
Modifier and Type | Class and Description |
---|---|
class |
SchedulingServiceAudit |
Modifier and Type | Method and Description |
---|---|
SchedulingService |
StatementContextEngineServices.getSchedulingService() |
SchedulingService |
StatementContext.getSchedulingService()
Returns service to use for schedule evaluation.
|
SchedulingService |
EPServiceProviderSPI.getSchedulingService()
Get the SchedulingService for this engine.
|
SchedulingService |
EPServiceProviderImpl.getSchedulingService() |
Modifier and Type | Method and Description |
---|---|
static StatementSpecRaw |
EPAdministratorHelper.compileEPL(String eplStatement,
String eplStatementForErrorMsg,
boolean addPleaseCheck,
String statementName,
SelectClauseStreamSelectorEnum defaultStreamSelector,
EngineImportService engineImportService,
VariableService variableService,
SchedulingService schedulingService,
String engineURI,
ConfigurationInformation configSnapshot,
PatternNodeFactory patternNodeFactory,
ContextManagementService contextManagementService,
ExprDeclaredService exprDeclaredService,
TableService tableService) |
protected static DatabaseConfigService |
EPServicesContextFactoryDefault.makeDatabaseRefService(ConfigurationInformation configSnapshot,
SchedulingService schedulingService,
SchedulingMgmtService schedulingMgmtService,
EngineImportService engineImportService)
Creates the database config service.
|
void |
StatementContext.setSchedulingService(SchedulingService schedulingService)
Sets the scheduling service
|
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) |
StatementContextEngineServices(String engineURI,
EventAdapterService eventAdapterService,
NamedWindowMgmtService namedWindowMgmtService,
VariableService variableService,
TableService tableService,
EngineSettingsService engineSettingsService,
ValueAddEventService valueAddEventService,
ConfigurationInformation configSnapshot,
MetricReportingServiceSPI metricReportingService,
ViewService viewService,
ExceptionHandlingService exceptionHandlingService,
ExpressionResultCacheService expressionResultCacheService,
StatementEventTypeRef statementEventTypeRef,
TableExprEvaluatorContext tableExprEvaluatorContext,
EngineLevelExtensionServicesContext engineLevelExtensionServicesContext,
RegexHandlerFactory regexHandlerFactory,
StatementLockFactory statementLockFactory,
ContextManagementService contextManagementService,
ViewServicePreviousFactory viewServicePreviousFactory,
EventTableIndexService eventTableIndexService,
PatternNodeFactory patternNodeFactory,
FilterBooleanExpressionFactory filterBooleanExpressionFactory,
TimeSourceService timeSourceService,
EngineImportService engineImportService,
AggregationFactoryFactory aggregationFactoryFactory,
SchedulingService schedulingService,
ExprDeclaredService exprDeclaredService) |
Modifier and Type | Class and Description |
---|---|
class |
SupportSchedulingServiceImpl |
Modifier and Type | Method and Description |
---|---|
static void |
SupportSchedulingServiceImpl.evaluateSchedule(SchedulingService service) |
static AgentInstanceContext |
SupportStatementContextFactory.makeAgentInstanceContext(SchedulingService stub) |
static AgentInstanceViewFactoryChainContext |
SupportStatementContextFactory.makeAgentInstanceViewFactoryContext(SchedulingService stub) |
static StatementContext |
SupportStatementContextFactory.makeContext(int statementId,
SchedulingService stub) |
static StatementContext |
SupportStatementContextFactory.makeContext(SchedulingService stub) |
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.
|
void |
MethodPollingViewable.validate(EngineImportService engineImportService,
StreamTypeService streamTypeService,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
ExprEvaluatorContext exprEvaluatorContext,
ConfigurationInformation configSnapshot,
SchedulingService schedulingService,
String engineURI,
Map<Integer,List<ExprNode>> sqlParameters,
EventAdapterService eventAdapterService,
StatementContext statementContext) |
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) |
void |
DatabasePollingViewable.validate(EngineImportService engineImportService,
StreamTypeService streamTypeService,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
ExprEvaluatorContext exprEvaluatorContext,
ConfigurationInformation configSnapshot,
SchedulingService schedulingService,
String engineURI,
Map<Integer,List<ExprNode>> sqlParameters,
EventAdapterService eventAdapterService,
StatementContext statementContext) |
Constructor and Description |
---|
DatabaseConfigServiceImpl(Map<String,ConfigurationDBRef> mapDatabaseRef,
SchedulingService schedulingService,
ScheduleBucket scheduleBucket,
EngineImportService engineImportService)
Ctor.
|
DataCacheExpiringImpl(double maxAgeSec,
double purgeIntervalSec,
ConfigurationCacheReferenceType cacheReferenceType,
SchedulingService schedulingService,
long scheduleSlot,
EPStatementAgentInstanceHandle epStatementAgentInstanceHandle,
TimeAbacus timeAbacus)
Ctor.
|
Constructor and Description |
---|
NamedWindowDispatchServiceImpl(SchedulingService schedulingService,
VariableService variableService,
TableService tableService,
boolean isPrioritized,
ManagedReadWriteLock eventProcessingRWLock,
ExceptionHandlingService exceptionHandlingService,
MetricReportingService metricReportingService) |
Constructor and Description |
---|
EPLTreeWalkerListener(org.antlr.v4.runtime.CommonTokenStream tokenStream,
EngineImportService engineImportService,
VariableService variableService,
SchedulingService schedulingService,
SelectClauseStreamSelectorEnum defaultStreamSelector,
String engineURI,
ConfigurationInformation configurationInformation,
PatternNodeFactory patternNodeFactory,
ContextManagementService contextManagementService,
List<String> scriptBodies,
ExprDeclaredService exprDeclaredService,
TableService tableService) |
Modifier and Type | Method and Description |
---|---|
SchedulingService |
StatementSpecMapContext.getSchedulingService() |
Modifier and Type | Method and Description |
---|---|
static StatementSpecRaw |
StatementSpecMapper.map(EPStatementObjectModel sodaStatement,
EngineImportService engineImportService,
VariableService variableService,
ConfigurationInformation configuration,
SchedulingService schedulingService,
String engineURI,
PatternNodeFactory patternNodeFactory,
NamedWindowMgmtService namedWindowMgmtService,
ContextManagementService contextManagementService,
ExprDeclaredService exprDeclaredService,
TableService tableService) |
Constructor and Description |
---|
StatementSpecMapContext(EngineImportService engineImportService,
VariableService variableService,
ConfigurationInformation configuration,
SchedulingService schedulingService,
String engineURI,
PatternNodeFactory patternNodeFactory,
NamedWindowMgmtService namedWindowMgmtService,
ContextManagementService contextManagementService,
ExprDeclaredService exprDeclaredService,
ContextDescriptor contextDescriptor,
TableService tableService) |
Modifier and Type | Method and Description |
---|---|
SchedulingService |
PatternContext.getSchedulingService()
Returns service to use for schedule evaluation.
|
Modifier and Type | Interface and Description |
---|---|
interface |
SchedulingServiceSPI
Service provider interface for scheduling service.
|
Modifier and Type | Class and Description |
---|---|
class |
SchedulingServiceImpl
Implements the schedule service by simply keeping a sorted set of long millisecond
values and a set of handles for each.
|
Modifier and Type | Method and Description |
---|---|
SchedulingService |
ViewFactoryContext.getSchedulingService()
Returns service to use for schedule evaluation.
|
Modifier and Type | Method and Description |
---|---|
void |
ValidatedView.validate(EngineImportService engineImportService,
StreamTypeService streamTypeService,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
ExprEvaluatorContext exprEvaluatorContext,
ConfigurationInformation configSnapshot,
SchedulingService schedulingService,
String engineURI,
Map<Integer,List<ExprNode>> sqlParameters,
EventAdapterService eventAdapterService,
StatementContext statementContext)
Validate the view.
|