Package | Description |
---|---|
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.view |
View infrastructure concerned with view creation and destroy, cloning and hooking views trees into filtering.
|
Modifier and Type | Method and Description |
---|---|
DataCache |
MethodPollingViewable.getOptionalDataCache() |
Modifier and Type | Method and Description |
---|---|
ThreadLocal<DataCache> |
MethodPollingViewable.getDataCacheThreadLocal() |
Constructor and Description |
---|
MethodPollingViewable(MethodStreamSpec methodStreamSpec,
DataCache dataCache,
EventType eventType,
ExprEvaluatorContext exprEvaluatorContext,
MethodPollingViewableMeta metadata) |
Modifier and Type | Class and Description |
---|---|
class |
DataCacheClearableMap
For use in iteration over historical joins, a
DataCache implementation
that serves to hold EventBean rows generated during a join evaluation
involving historical streams stable for the same cache lookup keys. |
class |
DataCacheExpiringImpl
Implements an expiry-time cache that evicts data when data becomes stale
after a given number of seconds.
|
class |
DataCacheLRUImpl
Query result data cache implementation that uses a least-recently-used algorithm
to store and evict query results.
|
class |
DataCacheNullImpl
Null implementation for a data cache that doesn't ever hit.
|
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.
|
DataCache |
DatabaseConfigServiceImpl.getDataCache(String databaseName,
StatementContext statementContext,
EPStatementAgentInstanceHandle epStatementAgentInstanceHandle,
DataCacheFactory dataCacheFactory,
int streamNumber) |
DataCache |
DatabaseConfigService.getDataCache(String databaseName,
StatementContext statementContext,
EPStatementAgentInstanceHandle epStatementAgentInstanceHandle,
DataCacheFactory dataCacheFactory,
int streamNumber)
Returns a new cache implementation for this database.
|
DataCache |
DatabasePollingViewable.getOptionalDataCache() |
protected DataCache |
DataCacheFactory.makeTimeCache(ConfigurationExpiryTimeCache expCache,
StatementContext statementContext,
EPStatementAgentInstanceHandle epStatementAgentInstanceHandle,
SchedulingService schedulingService,
ScheduleBucket scheduleBucket,
int streamNum) |
Modifier and Type | Method and Description |
---|---|
ThreadLocal<DataCache> |
DatabasePollingViewable.getDataCacheThreadLocal() |
Constructor and Description |
---|
DatabasePollingViewable(int myStreamNumber,
List<String> inputParameters,
PollExecStrategy pollExecStrategy,
DataCache dataCache,
EventType eventType)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
DataCache |
HistoricalEventViewable.getOptionalDataCache() |
Modifier and Type | Method and Description |
---|---|
ThreadLocal<DataCache> |
HistoricalEventViewable.getDataCacheThreadLocal()
Historical views are expected to provide a thread-local data cache
for use in keeping row (
EventBean references) returned during iteration
stable, since the concept of a primary key does not exist. |