Package | Description |
---|---|
com.espertech.esper.client.dataflow |
Client API for data flows.
|
com.espertech.esper.client.hook |
Callback interfaces for use with statement annotations.
|
com.espertech.esper.collection |
Internal collection classes
|
com.espertech.esper.core.context.activator |
Activation of streams for statement start.
|
com.espertech.esper.core.context.factory |
Statement agent instance factories.
|
com.espertech.esper.core.context.mgr |
Context management.
|
com.espertech.esper.core.context.subselect |
Subselect implementation.
|
com.espertech.esper.core.context.util |
Context partition utility or reference classes.
|
com.espertech.esper.core.deploy |
Module and deployment utility and parser.
|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
com.espertech.esper.core.start |
Classes related to start and stop of statements
|
com.espertech.esper.core.support |
Internal-use-only services for unit and regression testing
|
com.espertech.esper.core.thread |
This package contains classes to advanced threading options.
|
com.espertech.esper.dataflow.core |
Data flow core classes.
|
com.espertech.esper.dataflow.interfaces |
Data flow operator and related interface.
|
com.espertech.esper.dataflow.ops |
Data flow built-in operators.
|
com.espertech.esper.dataflow.ops.epl |
Data flow built-in operator's helper classes.
|
com.espertech.esper.epl.agg.factory |
Aggregator factories
|
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.enummethod.dot |
Enumeration method utility classes and input data sources.
|
com.espertech.esper.epl.enummethod.eval |
Enumeration method implementations.
|
com.espertech.esper.epl.expression.accessagg |
Access-aggregation expressions.
|
com.espertech.esper.epl.expression.core |
Core expression classes.
|
com.espertech.esper.epl.join.base |
Join process interfaces and glue code
|
com.espertech.esper.epl.join.hint |
Hints related to joins.
|
com.espertech.esper.epl.join.plan |
Inner join and outer join query planning
|
com.espertech.esper.epl.join.pollindex |
Poll result indexing strategies.
|
com.espertech.esper.epl.join.table |
Indexes for views
|
com.espertech.esper.epl.lookup |
Subquery execution strategies and lookup indexes
|
com.espertech.esper.epl.metric |
Services for metrics reporting, including global flag, repositories and threading.
|
com.espertech.esper.epl.named |
Named window classes are in this package
|
com.espertech.esper.epl.property |
Classes for handling events-within-events.
|
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.epl.table.merge |
Table on-merge handlers.
|
com.espertech.esper.epl.table.mgmt |
Table-related services and metadata.
|
com.espertech.esper.epl.table.onaction |
Table on-action handlers.
|
com.espertech.esper.epl.variable |
Variable service and variable collections
|
com.espertech.esper.epl.view |
Internal processing views for output rate limiting, filtering and internal event routing
|
com.espertech.esper.epl.virtualdw |
Virtual data window.
|
com.espertech.esper.event |
This package defines the internal event APIs.
|
com.espertech.esper.filter |
Main switchboard filtering and routing of incoming events to interested statements is performed in this package.
|
com.espertech.esper.metrics.instrumentation |
EPL instrumentation helpers.
|
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.pattern.guard |
Pattern guards that can define the lifetime of a pattern
|
com.espertech.esper.pattern.observer |
Pattern observer classes the observe timer events
|
com.espertech.esper.plugin |
APIs for plug-in adapter (for input-output) and plug-in event representation (event types and event objects) are in
this package.
|
com.espertech.esper.rowregex |
Match-recognize expression tree and state objects.
|
com.espertech.esper.schedule |
Package for timer callback scheduling
|
com.espertech.esper.util |
Utility classes that center around Java type handling, printing, reflection, debugging
|
com.espertech.esper.util.support |
Internal-use-only unit and regression test support classes.
|
com.espertech.esper.view |
View infrastructure concerned with view creation and destroy, cloning and hooking views trees into filtering.
|
com.espertech.esper.view.ext |
Extension views that providing services such as sorting, which don't fit much into other categories.
|
com.espertech.esper.view.internal |
Internal management views for buffering view results and providing these to joins.
|
com.espertech.esper.view.stat |
Views computing statistical values.
|
com.espertech.esper.view.std |
Base service views that perform typical SQL-like functions such as unique, grouping, size, last etc.
|
com.espertech.esper.view.stream |
View to event stream relationship service
|
com.espertech.esper.view.window |
Window views are in this package
|
Class and Description |
---|
EPRuntimeEventSender
For use by
EventSender for direct feed of wrapped events for processing. |
Class and Description |
---|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
Class and Description |
---|
StatementAgentInstanceLock |
Class and Description |
---|
EPServicesContext
Convenience class to hold implementations for all services.
|
EPStatementHandleCallback
Statement resource handle and callback for use with
FilterService and
SchedulingService . |
ExprEvaluatorContextStatement
Represents a statement-level-only context for expression evaluation, not allowing for agents instances and result cache.
|
StatementAgentInstanceLock |
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
Class and Description |
---|
EPServicesContext
Convenience class to hold implementations for all services.
|
InternalEventRouterDesc |
InternalRoutePreprocessView
View for use with pre-processing statement such as "update istream" for indicating previous and current event.
|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
StreamJoinAnalysisResult
Analysis result for joins.
|
Class and Description |
---|
EPServicesContext
Convenience class to hold implementations for all services.
|
EPStatementHandle
Class exists once per statement and hold statement resource lock(s).
|
EPStatementHandleCallback
Statement resource handle and callback for use with
FilterService and
SchedulingService . |
ExceptionHandlingService |
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
Class and Description |
---|
EPServicesContext
Convenience class to hold implementations for all services.
|
Class and Description |
---|
EPServicesContext
Convenience class to hold implementations for all services.
|
EPStatementDispatch
Interface for statement-level dispatch.
|
EPStatementHandle
Class exists once per statement and hold statement resource lock(s).
|
ExpressionResultCacheService |
StatementAgentInstanceFilterVersion
Records minimal statement filter version required for processing.
|
StatementAgentInstanceLock |
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
StatementContextCPPair |
StatementType
Type of the statement.
|
UpdateDispatchView
Update dispatch view to indicate statement results to listeners.
|
Class and Description |
---|
EPAdministratorSPI
Administrative SPI.
|
StatementEventTypeRef
Service for maintaining references between statement name and event type.
|
StatementIsolationService
Service for managing statement isolation.
|
Class and Description |
---|
ConfiguratorContext |
DeliveryConvertor
Converts a row of column selection results into a result for dispatch to a method.
|
DeliveryConvertorNull
Implementation that does not convert columns.
|
DeliveryConvertorObjectArr
Implementation of a convertor for column results that renders the result as an object array itself.
|
EngineEnvContext
Implements a JNDI context for providing a directory for engine-external resources such as adapters.
|
EngineLevelExtensionServicesContext
Marker interface for extension services that provide additional engine or statement-level extensions,
such as views backed by a write-behind store.
|
EPAdministratorContext
Context for administrative services.
|
EPAdministratorIsolatedSPI
Implementation for the admin interface.
|
EPAdministratorSPI
Administrative SPI.
|
EPContextPartitionAdminSPI |
EPContextPartitionExtract |
EPContextPartitionImportable |
EPContextPartitionImportResult |
EPIsolationUnitServices
Context for all services that provide the isolated runtime.
|
EPOnDemandPreparedQuerySPI |
EPPreparedQueryResult
The result of executing a prepared query.
|
EPPreparedStatementImpl
Prepared statement implementation that stores the statement object model and
a list of substitution parameters, to be mapped into an internal representation upon
creation.
|
EPRuntimeEventSender
For use by
EventSender for direct feed of wrapped events for processing. |
EPRuntimeIsolatedFactory |
EPRuntimeIsolatedSPI |
EPRuntimeSPI
SPI interface of the runtime exposes fire-and-forget, non-continuous query functionality.
|
EPServiceProviderIsolatedImpl
Implementation of the isolated service provider.
|
EPServiceProviderIsolatedSPI
SPU for isolated service provider.
|
EPServiceProviderSPI
A service provider interface that makes available internal engine services.
|
EPServicesContext
Convenience class to hold implementations for all services.
|
EPServicesContextFactory
Interface for a factory class to provide services in a services context for an engine instance.
|
EPServicesContextFactoryDefault.PackageName |
EPStatementFactory |
EPStatementHandle
Class exists once per statement and hold statement resource lock(s).
|
EPStatementHandleCallback
Statement resource handle and callback for use with
FilterService and
SchedulingService . |
EPStatementListenerSet
Provides update listeners for use by statement instances, and the management methods around these.
|
EPStatementSPI
Statement SPI for statements operations for state transitions and internal management.
|
ExceptionHandlingService |
ExpressionResultCacheEntryBeanAndCollBean
Cache entry bean-to-collection-of-bean.
|
ExpressionResultCacheEntryEventBeanArrayAndCollBean
Cache entry bean-to-collection-of-bean.
|
ExpressionResultCacheEntryEventBeanArrayAndObj
Cache entry bean-to-collection-of-bean.
|
ExpressionResultCacheEntryLongArrayAndObj
Cache entry bean-to-collection-of-bean.
|
ExpressionResultCacheForDeclaredExprLastColl
On the level of expression declaration:
a) for non-enum evaluation and for enum-evaluation a separate cache
b) The cache is keyed by the prototype-node and verified by a events-per-stream (EventBean[]) that is maintained or rewritten.
|
ExpressionResultCacheForDeclaredExprLastValue
On the level of expression declaration:
a) for non-enum evaluation and for enum-evaluation a separate cache
b) The cache is keyed by the prototype-node and verified by a events-per-stream (EventBean[]) that is maintained or rewritten.
|
ExpressionResultCacheForEnumerationMethod |
ExpressionResultCacheForPropUnwrap
On the level of indexed event properties: Properties that are contained in EventBean instances, such as for Enumeration Methods, get wrapped only once for the same event.
|
ExpressionResultCacheService |
ExpressionResultCacheStackEntry |
InsertIntoLatchFactory
Class to hold a current latch per statement that uses an insert-into stream (per statement and insert-into stream
relationship).
|
InsertIntoLatchSpin
A spin-locking implementation of a latch for use in guaranteeing delivery between
a single event produced by a single statement and consumable by another statement.
|
InsertIntoLatchWait
A suspend-and-notify implementation of a latch for use in guaranteeing delivery between
a single event produced by a single statement and consumable by another statement.
|
InsertIntoListener |
InternalEventRouteDest
Interface for a service that routes events within the engine for further processing.
|
InternalEventRouter
Interface for a service that routes events within the engine for further processing.
|
InternalEventRouterDesc |
InternalEventRouterEntry
Pre-Processing entry for routing an event internally.
|
InternalEventRouterImpl
Routing implementation that allows to pre-process events.
|
InternalRoutePreprocessView
View for use with pre-processing statement such as "update istream" for indicating previous and current event.
|
ResultDeliveryStrategy
Strategy for use with
StatementResultService to dispatch to a statement's subscriber
via method invocations. |
ResultDeliveryStrategyMap
A result delivery strategy that uses an "update" method that accepts a pair of map array.
|
ResultDeliveryStrategyObjectArr
A result delivery strategy that uses an "update" method that accepts a pair of object array array.
|
ResultDeliveryStrategyTypeArr
A result delivery strategy that uses an "update" method that accepts a underlying array
for use in wildcard selection.
|
StatementAgentInstanceLock |
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
StatementContextEngineServices |
StatementContextFactory
Interface for a factory class that makes statement context specific to a statement.
|
StatementContextFactoryDefault.AnnotationAnalysisResult
Analysis result of analysing annotations for a statement.
|
StatementEventTypeRef
Service for maintaining references between statement name and event type.
|
StatementExtensionSvcContext
Statement-level extension services.
|
StatementIsolationService
Service for managing statement isolation.
|
StatementLifecycleEvent
Event indicating statement lifecycle management.
|
StatementLifecycleEvent.LifecycleEventType
Event types.
|
StatementLifecycleObserver
Observer statement management events.
|
StatementLifecycleStmtContextResolver |
StatementLifecycleSvc
Handles statement management.
|
StatementLifecycleSvcImpl
Provides statement lifecycle services.
|
StatementLifecycleSvcImpl.EPStatementDesc
Statement information.
|
StatementLockFactory
Factory for the managed lock that provides statement resource protection.
|
StatementMetadata
Statement metadata.
|
StatementMetadataFactory
Statement metadata factory.
|
StatementMetadataFactoryContext
Statement metadata factory context.
|
StatementResultService
Interface for a statement-level service for coordinating the insert/remove stream generation,
native deliver to subscribers and the presence/absence of listener or subscribers to a statement.
|
StatementSemiAnonymousTypeRegistry |
StatementSemiAnonymousTypeRegistryImpl |
StatementType
Type of the statement.
|
StatementVariableRef
Service for maintaining references between statement name and variables.
|
UpdateDispatchFutureSpin
UpdateDispatchFutureSpin can be added to a dispatch queue that is thread-local.
|
UpdateDispatchFutureWait
UpdateDispatchFutureWait can be added to a dispatch queue that is thread-local.
|
UpdateDispatchView
Update dispatch view to indicate statement results to listeners.
|
UpdateDispatchViewBase
Convenience view for dispatching view updates received from a parent view to update listeners
via the dispatch service.
|
UpdateDispatchViewBlockingSpin
Convenience view for dispatching view updates received from a parent view to update listeners
via the dispatch service.
|
UpdateDispatchViewBlockingWait
Convenience view for dispatching view updates received from a parent view to update listeners
via the dispatch service.
|
Class and Description |
---|
EPPreparedQueryResult
The result of executing a prepared query.
|
EPServicesContext
Convenience class to hold implementations for all services.
|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
Class and Description |
---|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
Class and Description |
---|
EPRuntimeEventSender
For use by
EventSender for direct feed of wrapped events for processing. |
EPRuntimeImpl
Implements runtime interface.
|
EPServicesContext
Convenience class to hold implementations for all services.
|
EPStatementHandleCallback
Statement resource handle and callback for use with
FilterService and
SchedulingService . |
StatementResultServiceImpl
Implements tracking of statement listeners and subscribers for a given statement
such as to efficiently dispatch in situations where 0, 1 or more listeners
are attached and/or 0 or 1 subscriber (such as iteration-only statement).
|
Class and Description |
---|
EPServicesContext
Convenience class to hold implementations for all services.
|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
Class and Description |
---|
EPRuntimeEventSender
For use by
EventSender for direct feed of wrapped events for processing. |
EPServicesContext
Convenience class to hold implementations for all services.
|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
Class and Description |
---|
EPStatementHandleCallback
Statement resource handle and callback for use with
FilterService and
SchedulingService . |
StatementLifecycleEvent
Event indicating statement lifecycle management.
|
StatementLifecycleObserver
Observer statement management events.
|
Class and Description |
---|
UpdateDispatchView
Update dispatch view to indicate statement results to listeners.
|
Class and Description |
---|
StatementExtensionSvcContext
Statement-level extension services.
|
Class and Description |
---|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
StatementEventTypeRef
Service for maintaining references between statement name and event type.
|
StatementExtensionSvcContext
Statement-level extension services.
|
StatementResultService
Interface for a statement-level service for coordinating the insert/remove stream generation,
native deliver to subscribers and the presence/absence of listener or subscribers to a statement.
|
Class and Description |
---|
EngineLevelExtensionServicesContext
Marker interface for extension services that provide additional engine or statement-level extensions,
such as views backed by a write-behind store.
|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
Class and Description |
---|
ExpressionResultCacheStackEntry |
Class and Description |
---|
ExpressionResultCacheStackEntry |
Class and Description |
---|
StatementExtensionSvcContext
Statement-level extension services.
|
Class and Description |
---|
ExpressionResultCacheService |
StatementAgentInstanceLock |
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
StatementExtensionSvcContext
Statement-level extension services.
|
StatementType
Type of the statement.
|
Class and Description |
---|
EPStatementDispatch
Interface for statement-level dispatch.
|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
StreamJoinAnalysisResult
Analysis result for joins.
|
Class and Description |
---|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
Class and Description |
---|
StreamJoinAnalysisResult
Analysis result for joins.
|
Class and Description |
---|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
Class and Description |
---|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
Class and Description |
---|
StatementAgentInstanceLock |
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
Class and Description |
---|
EPServicesContext
Convenience class to hold implementations for all services.
|
StatementLifecycleEvent
Event indicating statement lifecycle management.
|
StatementLifecycleObserver
Observer statement management events.
|
StatementResultListener
Interface for statement result callbacks.
|
Class and Description |
---|
EPStatementHandle
Class exists once per statement and hold statement resource lock(s).
|
ExceptionHandlingService |
InternalEventRouteDest
Interface for a service that routes events within the engine for further processing.
|
InternalEventRouter
Interface for a service that routes events within the engine for further processing.
|
StatementAgentInstanceLock |
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
StatementResultService
Interface for a statement-level service for coordinating the insert/remove stream generation,
native deliver to subscribers and the presence/absence of listener or subscribers to a statement.
|
Class and Description |
---|
StatementExtensionSvcContext
Statement-level extension services.
|
Class and Description |
---|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
Class and Description |
---|
EPStatementHandle
Class exists once per statement and hold statement resource lock(s).
|
InternalEventRouteDest
Interface for a service that routes events within the engine for further processing.
|
InternalEventRouter
Interface for a service that routes events within the engine for further processing.
|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
Class and Description |
---|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
Class and Description |
---|
EPStatementHandle
Class exists once per statement and hold statement resource lock(s).
|
InternalEventRouteDest
Interface for a service that routes events within the engine for further processing.
|
InternalEventRouter
Interface for a service that routes events within the engine for further processing.
|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
StatementResultService
Interface for a statement-level service for coordinating the insert/remove stream generation,
native deliver to subscribers and the presence/absence of listener or subscribers to a statement.
|
Class and Description |
---|
StatementExtensionSvcContext
Statement-level extension services.
|
StatementResultService
Interface for a statement-level service for coordinating the insert/remove stream generation,
native deliver to subscribers and the presence/absence of listener or subscribers to a statement.
|
Class and Description |
---|
EPStatementHandle
Class exists once per statement and hold statement resource lock(s).
|
InternalEventRouter
Interface for a service that routes events within the engine for further processing.
|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
StatementResultService
Interface for a statement-level service for coordinating the insert/remove stream generation,
native deliver to subscribers and the presence/absence of listener or subscribers to a statement.
|
StatementVariableRef
Service for maintaining references between statement name and variables.
|
UpdateDispatchView
Update dispatch view to indicate statement results to listeners.
|
Class and Description |
---|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
Class and Description |
---|
EPRuntimeEventSender
For use by
EventSender for direct feed of wrapped events for processing. |
Class and Description |
---|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
StatementExtensionSvcContext
Statement-level extension services.
|
Class and Description |
---|
EPStatementHandle
Class exists once per statement and hold statement resource lock(s).
|
InternalEventRouterEntry
Pre-Processing entry for routing an event internally.
|
Class and Description |
---|
EPStatementHandle
Class exists once per statement and hold statement resource lock(s).
|
EPStatementHandleCallback
Statement resource handle and callback for use with
FilterService and
SchedulingService . |
ExceptionHandlingService |
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
StatementExtensionSvcContext
Statement-level extension services.
|
Class and Description |
---|
EngineLevelExtensionServicesContext
Marker interface for extension services that provide additional engine or statement-level extensions,
such as views backed by a write-behind store.
|
Class and Description |
---|
EngineLevelExtensionServicesContext
Marker interface for extension services that provide additional engine or statement-level extensions,
such as views backed by a write-behind store.
|
EPStatementHandleCallback
Statement resource handle and callback for use with
FilterService and
SchedulingService . |
Class and Description |
---|
EPRuntimeEventSender
For use by
EventSender for direct feed of wrapped events for processing. |
Class and Description |
---|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
Class and Description |
---|
EngineLevelExtensionServicesContext
Marker interface for extension services that provide additional engine or statement-level extensions,
such as views backed by a write-behind store.
|
Class and Description |
---|
EPServiceProviderSPI
A service provider interface that makes available internal engine services.
|
Class and Description |
---|
ExpressionResultCacheService |
StatementAgentInstanceLock |
StatementType
Type of the statement.
|
Class and Description |
---|
EPStatementHandle
Class exists once per statement and hold statement resource lock(s).
|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
StatementExtensionSvcContext
Statement-level extension services.
|
Class and Description |
---|
EPStatementHandleCallback
Statement resource handle and callback for use with
FilterService and
SchedulingService . |
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
Class and Description |
---|
EPStatementDispatch
Interface for statement-level dispatch.
|
EPStatementHandle
Class exists once per statement and hold statement resource lock(s).
|
InternalEventRouter
Interface for a service that routes events within the engine for further processing.
|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
Class and Description |
---|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
Class and Description |
---|
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|
Class and Description |
---|
StatementAgentInstanceLock |
Class and Description |
---|
EPStatementHandleCallback
Statement resource handle and callback for use with
FilterService and
SchedulingService . |
StatementContext
Contains handles to the implementation of the the scheduling service for use in view evaluation.
|